大佬,Flink CDC中我使用阿里云的实施计算Flink,采用CDAS语法同步任务,如果我想再当前正在运行的任务中,通过CDAS或者CTAS语法来新增加整库或表的 同步,如何增加allowNonRestoredState这个参数呢?我看官网上有说这个参数,但是没看到sql 怎么来添加?
主要是新加库,我们数据量小,为了节约资源,所有同步都放在一个任务中。
大佬,Flink CDC中我使用阿里云的实施计算Flink,采用CDAS语法同步任务,如果我想再当?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
在使用阿里云实时计算 Flink 的 CDC 功能时,如果你想在当前正在运行的任务中通过 CDAS 或 CTAS 语法新增整个数据库或表的同步,并且希望设置
allowNonRestoredState
参数,可以按照以下方式进行操作:1. 如果你已经停止了之前的作业,重新启动时会出现选择界面。在该界面中,可以找到一个选项来设置
allowNonRestoredState
参数。选择并启动这个选项即可。2. 如果你尚未停止之前的作业,需要先停止作业,然后再重新启动。在停止作业时,系统会保存作业的状态信息,包括参数配置。然后,在重新启动作业时,可以选择使用之前保存的状态信息,包括
allowNonRestoredState
参数。请注意,上述方法仅适用于使用 CDAS 语法进行 CDC 同步任务的情况。对于 CTAS 语法,可能无法直接设置
allowNonRestoredState
参数。在这种情况下,你可以考虑使用 Flink SQL DDL 或 Flink API 来定义和配置数据源和 Sink,并在代码中设置相关参数。总结起来,要在当前正在运行的 Flink CDC 任务中使用 CDAS 或 CTAS 语法新增整个库或表的同步,并设置
allowNonRestoredState
参数,可以使用上述提供的方法。根据你的需求和具体情况选择最适合的方式。希望这能帮助到你。如果还有其他问题,请继续提问。你停止作业后,再启动有这个界面可选,此回答整理自钉群“Flink CDC 社区”