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

大佬们,请教个问题,Flink CDC任务大家都是怎么做监控,报警?

大佬们,请教个问题,Flink CDC任务大家都是怎么做监控,报警?

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

大佬们 我想请教下Flink CDC 报这个错误是什么意思啊?

大佬们 我想请教下Flink CDC 报这个错误是什么意思啊?任务还能跑 但是会报这个错误org.apache.flink.util.FlinkException: Execution a1e6a7ca40077c6bfcb19d16a88a3a79_cbc357ccb763df2852fee8c4fc7d55f2_0_0 is unexpectedly no longer running on....

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

Flink CDC connection.pool.size这个参数,如果前面提交的任务是默认的?

Flink CDC connection.pool.size这个参数,如果前面提交的任务是默认的20,后面再提交的时候改成50,50能生效吗?

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

请问一下,Flink CDC sql同步数据,添加到20个任务(20张表)后,就提示获取不到连接?

问题1:请问一下,Flink CDC sql同步数据,添加到20个任务(20张表)后,就提示获取不到连接,这个是需要配置连接池吗? flink版本:1.17.0 ,flink-sql-connector-mysql-cdc-2.4.1。异常如下图:问题2:这个参数是全局的吗?这个不是给单独一个cdc设置的吗?

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

Flink CDC同一个job里的多张表的同步任务server-id也得不一样呀?

Flink CDC同一个job里的多张表的同步任务server-id也得不一样呀?

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

大佬们 flink 1.15.3 cdc 2.3.0 集群提交任务报这个错 Caused by: ?

大佬们 flink 1.15.3 cdc 2.3.0 集群提交任务报这个错 Caused by: java.lang.NoSuchMethodError: io.debezium.connector.mysql.MySqlConnection$MySqlConnectionConfiguration.(Lio/debezium/config/Configuration;Ljava/util/Pr....

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

Flink CDC 有没有大佬遇到是4万多条数据, 数据库的确也是这么多, 但是运行flink任务?

Flink CDC 有没有大佬遇到是4万多条数据, 数据库的确也是这么多, 但是运行flink任务的时候会一直重复无限读数据?

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

Flink CDC俩个任务source同一个mysql表第二个任务会报连接池问题 在flink ?

Flink CDC俩个任务source同一个mysql表第二个任务会报连接池问题 在flink sql能增加连接池大小或者禁止这种共享连接池的参数吗?

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

Flink各位大佬 yarn 任务kill 不掉 都是如何解决的?

Flink各位大佬 yarn 任务kill 不掉 都是如何解决的?

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

请教下各位大佬,flink任务报错: Job leader for job id lost ?

请教下各位大佬,flink任务报错: Job leader for job id lost leadership. 是啥原因导致的呢?

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

产品推荐

阿里云实时计算Flink

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

+关注