fanghj opened a new pull request #17653: URL: https://github.com/apache/flink/pull/17653
flink版本 1.13 cdc 版本 2.02 配置文件 flink-conf.yaml 设置如下 state.backend: filesystem state.checkpoints.dir: file:///tmp/flink-checkpoints state.savepoints.dir: file:///tmp/flink-savepoints sql-client 中设置如下： SET 'parallelism.default' = '1'; SET 'execution.checkpointing.interval' = '3s'; SET 'execution.checkpointing.externalized-checkpoint-retention' = 'RETAIN_ON_CANCELLATION'; SET 'execution.checkpointing.prefer-checkpoint-for-recovery' = 'true'; SELECT COUNT(OE.id) AS QTY ,SUM(OE.pay_amount) / 100 AS AMT FROM ODS_ORDER_INFO OE LEFT JOIN DIM_SHOP FOR SYSTEM_TIME AS OF OE.proc_time SH ON OE.shop_id = SH.shop_id WHERE SH.top_company_id = 1 AND OE.created_time >= '2021-11-01' ; 结果 ： cancel掉任务 ，从新 计算 checkpoint不生效 设置的state.checkpoints.dir: file 目录下 有 checkpoint文件生成 其中表用的时候阿里的RDS库 FLINK sql 连接 kafka 设置 checkpoint 也不生效 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
