SET 'state.checkpoints.dir' = 'hdfs:///bar/foo/';
SET 'execution.checkpointing.mode' = 'EXACTLY_ONCE';
SET 'execution.checkpointing.interval' = '30min';
SET 'execution.checkpointing.min-pause' = '20min';
SET 'execution.checkpointing.max-concurrent-checkpoints' = '1';
SET 'execution.checkpointing.prefer-checkpoint-for-recovery' = 'true';
-i,--init <initialization file> Script file that used to init
the session context. If get
error in execution, the sql
client will exit. Notice it's
not allowed to add query or
insert into the init file.
3条答案
按热度按时间a11xaf1n1#
检查点配置不能在flink sql客户端配置文件中设置,但可以在群集配置文件(flink-conf.yaml)中设置。
您至少应该配置
execution.checkpointing.interval
、state.backend
和state.checkpoints.dir
。比如说:
字符串
有关详细信息,请参阅检查点、容错和状态后端的配置文档。
uurv41yg2#
就我在文档中看到的,你应该能够从sql客户端通过设置这样的属性来做到这一点:
字符串
o75abkj43#
在调用sql客户端时,您实际上可以传入一个init sql文件,而不必更新群集配置文件。
./sql-client
字符串
然后,您可以在文件中指定
型
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sqlclient/