Flink学习笔记——Table和SQL API

Table API官方文档参考

https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/tableapi/

RowKind

 

自定义修改debezium-json format

Flink 1.11.1:flink CDC Debezium自定义修改debezium-json格式

Flink cdc自定义format格式数据源

 

如果要在flink sql中使用checkpoint，可以使用set命令，如下

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';