在flinksql中使用sql客户机时,我们如何使用查询配置?

cwdobuhd  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(402)

在flinksql中使用sql客户机时,我们如何使用查询配置?
与下面的链接中提到的相同的方式https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/query_configuration.html
要使用空闲状态保留时间。

gg0vcinb

gg0vcinb1#

flink的sql客户机可以在启动时读取yaml配置文件,该文件可以包含空闲状态保留规范。例如,您可以通过 sql-client.sh embedded -e sql-client-config.yaml 其中配置文件包含

execution:
  planner: old                      # optional: either 'old' (default) or 'blink'
  type: streaming                   # required: execution mode either 'batch' or 'streaming'
  result-mode: table                # required: either 'table' or 'changelog'
  max-table-result-rows: 1000000    # optional: maximum number of maintained rows in
                                    #   'table' mode (1000000 by default, smaller 1 means unlimited)
  time-characteristic: event-time   # optional: 'processing-time' or 'event-time' (default)
  parallelism: 1                    # optional: Flink's parallelism (1 by default)
  periodic-watermarks-interval: 200 # optional: interval for periodic watermarks (200 ms by default)
  min-idle-state-retention: 0       # optional: table program's minimum idle state time
  max-idle-state-retention: 0       # optional: table program's maximum idle state time

详见文档。

相关问题