这个问题是由于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...
Flink CDC用table-api ，某个字段需要用java方法转换一下有什么好的办法吗？
Flink CDC用table-api ，sql selcet 某个字段需要用java方法转换一下有什么好的办法吗？
flink cdc stream api 2.2.1 mysql 一条很大的字段数据异常了有人遇
flink cdc stream api 2.2.1 mysql 一条很大的字段数据异常了有人遇到过么？
Flink 的 Scala API 怎么指定 时间字段
代码如下 import com.alibaba.fastjson.JSON import com.alibaba.fastjson.serializer.SerializeFilter import org.apache.flink.api.common.typeinfo.TypeInformation import org.apache.flink.streaming.api.TimeChar....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
API flink相关内容
- flink cdc数据集成API
- flink集成API
- flink yaml API
- flink API起始
- flink datastream API设置
- flink datastream API binlog
- flink API holo
- flink API设置
- flink datastream API
- flink API checkpoint
- flink API加载
- flink流批一体API
- flink变更API
- flink API层次
- flink运行API
- flink rest API
- flink作业API
- flink报错API
- flink cdc datastream API
- flink产品API
- flink stream API
- flink table API
- flink监控API
- flink sql table API
- flink connector API
- flink connector table API
- flink sql connector savepoint table API
- flink API分区表
- flink API监控
- flink API任务
API更多flink相关
- flink caused API
- flink API jdbc
- flink streaming API
- flink API捕获
- 实时计算flink版flink API
- flink job API
- flink API delete
- flink API内存
- flink API存储
- flink API参数
- flink table API sql
- flink cdc stream API
- flink实战API编程
- flink cdc table API
- flink教程高级API
- flink API jar
- flink API程序
- flink table sql API
- flink教程API
- flink API同步
- flink cdc sql API
- flink API source
- flink API datastream
- flink pyflink API
- flink API格式
- flink教程批流一体API
- flink API办法
- flink cdc API任务
- flink dataset API
- flink API模式
