问答 2024-04-02 来自:开发者社区

我想问一下,我用的是flink mysql cdc2.3.0,这个效果怎么做?

我想问一下,我用的是flink mysql cdc2.3.0,然后一开始设置.tableList("test.test.*,test.test,test.test1"),然后我新建一张表test2,接着把任务停掉,再在tableList("test.test.*,test.test,test.test1,test.test2")添加了,从checkpoint启动,为什么不生效呢?

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

Flink CDC2.3.0连接oracle 运行久了会把连接池占满 有人遇到过嘛?

Flink CDC2.3.0连接oracle 运行久了会把连接池占满 有人遇到过嘛?

问答 2023-07-13 来自:开发者社区

flink1.14.6 + cdc2.3.0 在debezium-connector-mysql-?

flink1.14.6 + cdc2.3.0 在debezium-connector-mysql-1.6.4.Final.jar和flink-connector-mysql-cdc-2.3.0.jar中同时存在io.debezium.connector.mysql.MySqlConnection$MySqlConnectionConfiguration但构造方法不同,参考https://gith....

问答 2023-07-01 来自:开发者社区

Flink CDC2.3.0运行一段时间后就会报这个错A slave怎么搞-?是运行十几个小时才报的

Flink CDC2.3.0运行一段时间后就会报这个错A slave with the same server_uuid/server_id as this slave has connected to the master怎么搞-?是运行十几个小时才报的

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

flink15.3,cdc2.3.0 对应vvr-6.0.2-flink-1.15 报错这是为什么?

flink15.3,cdc2.3.0 对应vvr-6.0.2-flink-1.15 报错java.lang.NoClassDefFoundError: org/apache/flink/calcite/shaded/com/google/common/collect/Lists ?这是为什么?13的可以

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

大佬们,请教下,Flink CDC2.3.0版本,有人遇到这个问题么?

大佬们,请教下,Flink CDC2.3.0版本,有人遇到这个问题么?Failed to deserialize data of EventHeaderV4{timestamp=1686900887000, eventType=EXT_UPDATE_ROWS, serverId=407803, headerLength=19, dataLength=234399, nextPosition=88....

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

各位大佬是否遇到过flink1.15.3+cdc2.3.0同步oracle 连接数一直不释放的问题?

各位大佬是否遇到过flink1.15.3+cdc2.3.0同步oracle 连接数一直不释放的问题吗 请问大佬们怎么解决的?一直增长 知道连接数满

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

各位老师请问有谁能帮忙告知下flink1.16.1,flink mysql cdc2.3.0读取my

各位老师请问有谁能帮忙告知下flink1.16.1,flink mysql cdc2.3.0读取mysql数据,initial模式,不报错也不输出数据可能的原因吗? 用flink1.13.6,cdc2.2可以读出来,开启了,有数据的,之前一直用的这个版本测试,后面领导说要升级成1.16.1的版本,就读不出数据了,换成1.16.0也不行,看了。也试了用1.15.4,数据也出不来,没爆出来更多日子就....

问答 2023-04-26 来自:开发者社区

为啥Flink CDC2.3.0版本 死活不能用啊?

为啥Flink CDC2.3.0版本 死活不能用啊? ide 编译 linux编译 maven下载 都不行、

问答 2023-04-26 来自:开发者社区

Flink中我设置了这个 还是跟之前一样?flink1.16.1 cdc2.3.0 env.getC

Flink中我设置了这个 还是跟之前一样?flink1.16.1 cdc2.3.0 env.getCheckpointConfig().setCheckpointTimeout(10000); 能加载一部分数据 但是到了splitStart=[1025972], splitEnd=[1072607] 这里就不行了

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

产品推荐

阿里云实时计算Flink

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

+关注