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

请问 flink cdc中这里作为json入参,咋都被搞了啊?

请问 flink cdc中这里作为json入参,咋都被搞了啊?

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

Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},?

Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},一个是after:{},最后一个是op?我这些都没有,只有before,after,op

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

Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?

问题1:Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?问题2:不能用debezium-json格式拿op字段数据吗

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

请问Flink中是否可以在 json_query 函数的 path 中使用变量,例如 select?

请问Flink中是否可以在 json_query 函数的 path 中使用变量,例如 select json_query( col_a, col_b) from table_a?报错 Caused by: org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call: JSON_QUERY(STRING, ST....

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

请问Flink 中是否可以在 json_query 函数的 path 中使用变量,例如 ?

请问Flink 中是否可以在 json_query 函数的 path 中使用变量,例如 select json_query( col_a, col_b) from table_a 报错 Caused by: org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call: JSON_QUERY(STRING, S....

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

Flink CDC中话说debezium json中能够获取表的主键吗?

Flink CDC中话说debezium json中能够获取表的主键吗? canal json中很明确

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

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗?

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗,可以支持canal json吗?暂时没有接paimon,我是需要从json中获取表的主键以便后续操作,canal json中有pkNames字段,debezuim json中我没发现代码主键的字段,不知道是没有还是我没找到

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

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

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

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

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

Flink CDC中这里除了支持有支持canal json吗!大佬们 都用的什么版本啊?

Flink CDC中这里除了支持JsonDebeziumDeserializationSchema, 有支持canal json吗 大佬们 都用的什么版本啊?

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

开发与运维

集结各类场景实战经验,助你开发运维畅行无忧

+关注