你好，flink oracle cdc-2.4 加上checkpoint设置后，会出现:file is not a valid field name。请问这是什么原因？ –set ‘execution.savepoint.path’ = ‘hdfs://192.168.10.1:8020/eas/saleorder/d51068fec17d01df3e2c91bd194b71de/chk-462/_metadata’; set ‘execution.checkpointing.interval’ = ‘120 s’; set ‘execution.checkpointing.externalized-checkpoint-retention’ = ‘RETAIN_ON_CANCELLATION’; set ‘state.checkpoints.dir’ = ‘hdfs://192.168.10.1:8020/eas/saleorder’;？
你好，flink oracle cdc-2.4 加上checkpoint设置后，会出现:file ？[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
int 是一种用于实现容错的机制，可以在任务故障时恢复之前的状态，保证数据的一致性。您可以在 Flink 作业提交时通过设置参数来配置 Checkpoint，例如：
bash
Copy
flink run -d -c com.example.MyJob
–set checkpointing.mode=EXACTLY_ONCE
–set execution.checkpointing.interval=10000
my-job.jar
在上述示例中，我们使用了 –set 参数来设置 Checkpoint 相关的参数，例如 checkpointing.mode 和 execution.checkpointing.interval。需要注意的是，参数名必须是 Flink 支持的合法参数名，否则会出现 “file is not a valid field name” 的错误。
根据您提供的信息，错误信息中出现了 “file” 这个单词，这可能是因为您在设置参数时使用了非法的参数名。建议您检查一下提交作业时设置的参数名是否正确，确保参数名与 Flink 官方文档中所列出的参数名一致。