如何创建和使用Kafka JSON Catalog
配置Kafka JSON Catalog后，您可以在Flink全托管作业开发中直接访问Kafka集群中格式为JSON的Topic，无需再定义Schema。本文为您介绍如何在Flink全托管模式下创建、查看及删除Kafka JSON Catalog。
Flink SLS的connector不支持JSON 的formatter？
Flink SLS的connector不支持JSON 的formatter？
Flink CDC 里mysql的cdc出来的json op字段有哪几种值？是 c r u d 吗？
Flink CDC 里mysql的cdc出来的json op字段有哪几种值？是 c r u d 吗？
在Flink使用cdas语法，mysql的json类型到了hologres会变成什么类型？
在Flink使用cdas语法，同步mysql数据到hologres(开启了字段类型宽容模式'enableTypeNormalization' = 'true')，mysql的json类型到了hologres会变成什么类型？在文档上没找到映射关系。
Flink报错问题之使用debezium-json format报错如何解决
问题一：flink sql报错 Could not find any factory for identif 各位好，写了个demo，代码如下，在本地跑没有问题，提交到yarn session上报错： Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for iden...
Flink问题之嵌套 json 中string 数组的解析异常如何解决
问题一：嵌套 json 中string 数组的解析异常 我使用 flink 1.9 处理嵌套 json， 它嵌套了一个string数组，构造出的 table schema结构为： Row(parsedResponse: BasicArrayTypeInfo , timestamp: Long) 执行作业后会发生报错如下，出现 object 类型和string 类...
Flink SQL问题之复杂JSON解析如何解决
问题一：ddl es 报错 源码如下: CREATE TABLE buy_cnt_per_hour ( hour_of_day BIGINT, buy_cnt BIGINT ) WITH ( 'connector.type' = 'elasticsearch', 'conne...
flink问题之使用debezium-json format报错如何解决
问题一：flink 1.11 es未定义pk的sink问题 根据文档[1]的描述，1.11的es sql connector如果在ddl里没有声明primary key，将会使用append模式sink数据，并使用es本身生成的id作为document_id。但是我在测试时发现，如果我的ddl里没有定义primary key，写入时没有正确生成document_id，反而是将i...
Flink CDC里flink-sql 中json_array 类型 怎么转成 array类型？
Flink CDC里flink-sql 中 json_array 类型 怎么转成 array 类型？
这个问题是由于Flink的Table API在处理MySQL数据时，将MULTISET类型的字段转换为了JSON格式
flink1.14.5我用table api从mysql写入es，mysql源中有一个字段通过collect聚合函数默认得到了MULTISET类型，该字段需要对应输出到es的array类型中，但是报错：Exception in thread "main" java.lang.UnsupportedOperationExcep...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
开发与运维
集结各类场景实战经验，助你开发运维畅行无忧
+关注