问答 2023-09-06 来自:开发者社区

Flink CDC2.2 任务停止 新加表 从checkpoint恢复 会报错?

Flink CDC2.2 任务停止 新加表 从checkpoint恢复 会报错?

问答 2023-09-06 来自:开发者社区

Flink CDC如果里面有异步任务或者定时任务,一样还在执行?

Flink CDC我发现 FlinkJava部署以后 当一个job 自己cancel后,呢个任务其实没有被杀死。如果里面有异步任务或者定时任务,一样还在执行?我在一个人job里 弄了个定时器,每隔一段时间执行一次。后来我把这个任务cancel,看了一下日志,这个定时器竟然还在执行。这个 有什么钩子嘛?可以检测到job已经被我cancel了,然后我自己把定时器删了也可以。

问答 2023-09-06 来自:开发者社区

Flink CDC oracle 任务停止 这个问题有遇到过吗?

Flink CDC oracle 任务停止 新加表 从savepoint 恢复 会报错 ,这个问题有遇到过吗?

问答 2023-09-06 来自:开发者社区

Flink CDC2.4.1任务停止 新加表 重启任务报这个错?

Flink CDC2.4.1任务停止 新加表 重启任务报这个错?Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mysql_binlog_source,ts_m....

问答 2023-09-06 来自:开发者社区

有遇到过Flink CDC。任务进程被kill 之后。导致他一直重启失败的问题吗?

有遇到过Flink CDC。任务进程被kill 之后。他又从最早的scn开始。因为归档日志被删除。导致他一直重启失败的问题吗?

问答 2023-09-06 来自:开发者社区

Flink CDC我是在程序里面把整库同步进行了集成,用savepoint重启任务就是报错?

问题1:Flink CDC我是在程序里面把整库同步进行了集成,程序里启停任务,现在问题是同步数据时候,以前是5张表,一个任务,现在改为7张表一个任务后,用savepoint重启任务就是报错?需要设置allowNonRestoredState参数问题2:命令方式,我也看到有,就是程序里配置,一直找不到

问答 2023-09-06 来自:开发者社区

大家有没有遇到过Flink CDC多表关联任务,运行几天后,但并没有数据输出导致数据丢失问题?

问题1;大家有没有遇到过Flink CDC多表关联任务,运行几天后,join表数据更新,但并没有数据输出导致数据丢失问题?问题2:是查看flink的日志吗?是的,用的是table api方式的

问答 2023-09-06 来自:开发者社区

我任务现在大面积报错ck失败 跟上午发那个原因一致 是Flink CDC版本问题导致的嘛?

我任务现在大面积报错ck失败 跟上午发那个原因一致 是Flink CDC版本问题导致的嘛?

问答 2023-09-05 来自:开发者社区

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,报错,为什么?

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,运行同样的任务,报错,查看版本都是flink 1.13版本,Flink报错是为什么?

问答 2023-09-05 来自:开发者社区

Flink运行一个任务,但是部署到服务器后,运行同样的任务,报错,为什么?

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,运行同样的任务,报错,查看版本都是flink 1.13版本,有人知道Flink报错这个是为什么吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注