问答 2024-05-16 来自:开发者社区

flinkcdc模式去读holo表的binlog的时候报错,怎么解决?

flinkcdc模式去读holo表的binlog的时候报错,怎么解决?Realtime ingestion service (holohub) not enabled or its endpoint invalid. org.apache.flink.table.api.ValidationException: SQL validation failed. Realtime ingestion.....

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

FlinkCDC中使用 mysql-cdc 2.3.0的版本指定binlog位置读取报错,什么原因?

Flink CDC中使用 mysql-cdc 2.3.0的版本,指定binlog位置读取,确实读到数据,但几分钟后,报错说binglog已经在server端不存在了,但是已经去mysql查看了,binlog文件确实是存在,这个是什么原因?主从mysql, 从库mysql读的Caused by: java.lang.IllegalStateException: The connector is t....

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

大佬们 我想问下我flinkcdc选择从binlog固定位置启动的话开启checkpoint会报错是

大佬们 我想问下我flinkcdc选择从binlog固定位置启动的话开启checkpoint会报错是什么原因呀?用StartupOptions.initial()就没问题,这个是从savepoint恢复报的错

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

想问下我flinkcdc选择从binlog固定位置启动的话开启checkpoint会报错是什么原因?

我想问下我flinkcdc选择从binlog固定位置启动的话开启checkpoint会报错是什么原因呀?

问答 2022-09-17 来自:开发者社区

flinkcdc出现了一些问题,想在启动的时候从binlog文件的指定位置读报错是怎么回事

报错Failed to deserialize data of EventHeaderV4{timestamp=1663310484000, eventType=EXT_DELETE_ROWS, serverId=183406, headerLength=19, dataLength=86, nextPosition=3887153, flags=0}

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

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等