问答 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报错这个是为什么吗?

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

Flink运行一个任务,查看版本都是flink 1.13版本有人知道报错这个是为什么吗?

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

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

Flink UC,任务切换成UC比AC的停顿时间还要长 ?

哪位大佬清楚Flink UC啊,任务切换成UC比AC的停顿时间还要长 ?

问答 2023-08-31 来自:开发者社区

Flink CDC 如何配置可以实现 仅执行全量同步一次后 结束任务。 意思是当作批任务执行一次。

采用dataStream方式 而非sql方式版本 2.1.1+1.13.6

问答 2023-08-29 来自:开发者社区

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?

问答 2023-08-29 来自:开发者社区

有个任务在阿里云Flink跑着跑着就出现OOM,但我们不能开普罗米修斯去监测,你们有办法吗?

Flink有个任务在阿里云FLINK跑着跑着就出现OOM,但我们又不能开普罗米修斯去监测,你们这边可以有办法帮到我们吗?不想开监控,费用贵,运行日志排查可以吗?

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

产品推荐

阿里云实时计算Flink

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

+关注