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

Flink CDC里这个入参json为什么会变成这样?

Flink CDC里这个入参json为什么会变成这样?代码是这样的,拿到json就是乱七八糟,不知道为什么?

问答 2024-01-17 来自:开发者社区

Flink中sql作业发送json格式到kafka,可以指定json里的key值吗?

Flink中sql作业发送json格式到kafka,可以指定json里的key值吗?

问答 2024-01-09 来自:开发者社区

Flink在算子里之后要怎么处理啊,调用第三方json解析包去解析json吗?

Flink在算子里之后要怎么处理啊,调用第三方json解析包去解析json吗?

问答 2024-01-09 来自:开发者社区

Flink CDC这里传json,双引号会被去掉,怎么办?

Flink CDC这里传json,双引号会被去掉,怎么办?用这个拿参数:ParameterTool parameterTool = ParameterTool.fromArgs(args);

问答 2024-01-09 来自:开发者社区

请问一下Flink CDC这个参数不能用json格式吗?

请问一下Flink CDC这个参数不能用json格式吗?

问答 2023-12-31 来自:开发者社区

Flink CDC中with需要什么特殊参数吗,还是直接用json函数去取值?

Flink CDC中with需要什么特殊参数吗,还是直接用json函数去取值?

问答 2023-12-24 来自:开发者社区

有没有人遇到Flink CDC1.16 解析json乱码的问题?

有没有人遇到Flink CDC1.16 解析json乱码的问题?

问答 2023-12-20 来自:开发者社区

Flink CDC使用的是kafka canal json作为数据变更源,cdc3.0未来会支持么?

Flink CDC使用的是kafka canal json作为数据变更源,cdc 3.0未来会支持么?

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

Flink中canal-json那个binlog的type怎么能过滤出insert和update?

Flink中canal-json 那个binlog的type怎么能过滤出insert和update的呀?

文章 2023-12-07 来自:开发者社区

Apache Flink SQL目前还不支持直接解析JSON字符串并将其转换为预期的数据类型

Apache Flink SQL目前还不支持直接解析JSON字符串并将其转换为预期的数据类型。你可以在Flink SQL中使用STRING_TO_ARRAY函数将字符串转换为数组。 以下是一个示例,展示了如何将字符串转换为数组: SELECT STRING_TO_ARRAY(JSON_QUERY('{"a":[{"c":"...

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

开发与运维

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

+关注