备案控制台

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请教各位大佬，flinksql可以解析kafka中嵌套json解析成多个流，写入多张表吗？

请教各位大佬，flinksql可以解析kafka中嵌套json解析成多个流，写入多张表吗？

展开

收起

后端老大 2023-02-12 17:25:02 572 0

2 条回答

写回答

取消提交回答

认真学习的heart

可以使用Flink SQL的CREATE TABLE语句来定义表，然后使用INSERT INTO语句将数据写入表中。

2023-02-13 11:39:32

赞同展开评论打赏
解决问题123

参考DataStream的侧输出，FlinkSQL 怎么处理就不知道了。 https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/dev/datastream/side_output/

此答案来自钉钉群“【2】Apache Flink China 社区”

2023-02-12 18:10:40

赞同展开评论打赏

问答分类：

消息中间件 JSON Kafka 数据格式云消息队列 Kafka 版实时计算 Flink版云解析DNS

问答标签：

云解析DNS json JSON解析云消息队列 Kafka 版json flinksql云消息队列 Kafka 版云消息队列 Kafka 版解析

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答

实时计算 Flink版

flink sql输出到upsert kafka 下游再消费一般是upsert 还是 json呀？

28

0

0

如何通过Kafka Connector解析嵌套JSON格式的数据

53

1

0

flink kafka debezium-json读取更新的数据，没有op 怎么获取op为u的数据？

14

0

0

flinksql消费kafka然后look up join doris纬表，出现下面问题怎么解决？

22

1

0

flinkcdcSQL处理Kafka数据，json数据是数组的，建表结构该怎么写？[{},{}]。？

15

0

0

在机器学习PAI中，有没有用flinkSQL直接连kafka的？

20

1

0

kafka写入的数据如果是json数组，可以批量写入到tablestore吗？

21

0

0

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？

21

1

0

如果用flinksql的方式同步mysql数据到kafka，是类似DTS那样吗？

15

1

0

Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办？

32

0

0

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

热门讨论

热门文章

FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？

Flink CDC有遇见这个问题的吗？

各位大佬，flinksql可以实现多流join吗，比如十几张表join

Flink CDC中mysql cdc 的那个server_id 设置的话，一般是怎么设置的？

flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？

请问如何用flink sql客户端用yarn application模式提交任务呢？

Flink sql将数组炸开，实现hive的explode函数的效果，还有什么其他好的方式？

mysql是cst时区，不修改msyq时区的情况下， flink改怎么配置时区？

flink 和flink cdc 和 flink sql client 啥区别？

Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行

展开全部

Apache Paimon V0.9最新进展

阿里云实时计算产品案例&解决方案汇总

Flink Checkpoint 问题排查实用指南

Flink SQL 功能解密系列 —— 数据去重的技巧和思考

携程实时智能检测平台建设实践

如何分析及处理 Flink 反压？

Flink Batch SQL 1.10 实践

Flink Forward Asia 2019 - 总结和展望（附PPT下载链接）

阿里重磅开源全球首个批流一体机器学习平台Alink，Blink功能已全部贡献至Flink

阿里巴巴大规模应用Flink的踩坑经验：如何大幅降低 HDFS 压力？

展开全部

相关课程

更多

云计算工程师解析与实战-网络专家篇（体验版）

579

3

去学习

深入解析Docker容器化技术

1581

50

去学习

分布式消息系统 Kafka 快速入门

921

24

去学习

Java面试疑难点解析 - 面试技巧及语言基础

3886

61

去学习

Java面试疑难点解析 - Java Web开发

770

36

去学习

Java面试疑难点解析 - 系统架构及项目设计

1605

25

去学习

相关电子书

更多

神龙云服务器产品及技术深度解析 立即下载

弹性创造价值：基于ECS的最佳性价比实践解析 立即下载

又快又稳：阿里云下一代虚拟交换机解析 立即下载

相关实验场景

更多