问答 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. 是啥原因导致的呢?

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

Flink sql-client提交的sql任务能写到sink表,通过flink ?

Flink sql-client提交的sql任务能写到sink表,通过flink sql-gateway提交的sql任务写不进去,有人遇见过吗?

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

flink管理界面,有任务暂停的按钮吗?- "INITIALIZING":初始化中

flink管理界面,有任务暂停的按钮吗?- "INITIALIZING":初始化中 "CREATED":已创建 "RUNNING":运行中 "FAILING":失败中 "FAILED":已失败 "CANCELLING":取消中 "CANCELED":已取消 "FINISHED":已完成 "RESTARTING":重启中 "SUSPENDED":已暂停 "RECONCILING":调节中我看文档.....

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

请教Flink CDC中environment.execute("DbForJob")这个执行了一?

请教Flink CDC中environment.execute("DbForJob")这个执行了一个任务,怎么停止这个服务呢?

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

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没?

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没有了,然后我重启了,有没有办法从上一次checkpoint开始操作呢?

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

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

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

产品推荐

阿里云实时计算Flink

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

+关注