问答 2024-08-18 来自:开发者社区

flink cdc有遇到raw format 解析中文乱码的时候吗?

flink cdc有遇到raw format 解析中文乱码的时候吗?正常json解析就没乱码,raw就有

问答 2024-08-07 来自:开发者社区

在Flink CDC中,要读很多gtid,会存在过期的gtid,就会报binlog解析的错误?

在Flink CDC中,show master status 和gtid_purged 有很多。cdc 在全量转增量阶段算出来,要读很多gtid,会存在过期的gtid,就会报binlog解析的错误?

问答 2024-07-31 来自:开发者社区

在Flink CDC中,用过 OpenLogReplicator解析 oracle log不?

在Flink CDC中,用过 OpenLogReplicator解析 oracle log不?

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

对于Flink CDC,怎么在解析binlog的时候判断是datetime类型,然后减8小时给它?

对于Flink CDC,怎么在解析binlog的时候判断是datetime类型,然后减8小时给它?

问答 2024-06-03 来自:开发者社区

Flink MySQL CDC使用tablename正则表达式不能解析逗号怎么办

Flink MySQL CDC使用tablename正则表达式不能解析逗号怎么办

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

Flink CDC有人解析过待压缩格式的oracle clob吗?

Flink CDC有人解析过待压缩格式的oracle clob吗,我看数据输入是个EMPTY_CLOB?

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

Flink CDC中flinksql怎么解析json数组[{},{}]格式数据?

Flink CDC中flinksql怎么解析json数组[{},{}]格式数据?

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

Flink CDC里这种数据 flinksql 该如何解析?

Flink CDC里这种数据 flinksql 该如何解析?[{"id":"999","name":"abc","date":"1990-10-14"},{"id":"999","name":"abc","date":"1990-10-14"}]kafka里面的。还是一个json数组flink sql

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

Flink cdc默认解析出来的这个transaction字段, 是什么含义昂?

Flink cdc默认解析出来的这个transaction字段, 是什么含义昂?

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

Flink CDC中有没有人遇到过解析binlog 顺序的问题?

在Flink CDC中,有人遇到过解析binlog的顺序问题吗?数据库的binlog顺序是先删除后新增,但CDC解析出来的顺序却是先新增后删除。使用Flink SQL读取MySQL的binlog再写入到Kafka时,不论是在CDC版本2.2.1还是2.4.2,以及Flink版本1.15上都出现了这个问题。就算将Flink的并行度设为1,这个问题仍然偶尔发生,且不是必然出现,另外在GitHub上也....

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

产品推荐

相关镜像
AI助理

你好,我是AI助理

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