Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},?
Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},一个是after:{},最后一个是op?我这些都没有,只有before,after,op
Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?
问题1:Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?问题2:不能用debezium-json格式拿op字段数据吗
请问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....
请问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....
Flink CDC中话说debezium json中能够获取表的主键吗?
Flink CDC中话说debezium json中能够获取表的主键吗? canal json中很明确
Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗?
Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗,可以支持canal json吗?暂时没有接paimon,我是需要从json中获取表的主键以便后续操作,canal json中有pkNames字段,debezuim json中我没发现代码主键的字段,不知道是没有还是我没找到
大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?
大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?
大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?
大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?
Flink CDC中这里除了支持有支持canal json吗!大佬们 都用的什么版本啊?
Flink CDC中这里除了支持JsonDebeziumDeserializationSchema, 有支持canal json吗 大佬们 都用的什么版本啊?
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
开发与运维
集结各类场景实战经验,助你开发运维畅行无忧
+关注