云消息队列 Kafka 版sql 的相关内容

大佬，请教一个与Flink SQL的事件时间和watermark的场景：读入kafka流#Flink

大佬，请教一个与Flink SQL的事件时间和watermark的场景：读入kafka流的时候水位设置为： WATERMARK FOR ts AS ts - INTERVAL '20' SECOND 聚合的时候，时间窗口是一分钟： GROUP BY TUMBLE(ts, INTERVAL '1' ...

flink SQL中要用kafka连接器作为sink，参数需要怎么指定? #Flink

消息队列Kafka入门课程

4 课时 |

3098 人已学 |

加入学习

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

24 课时 |

640 人已学 |

加入学习

咨询一个flink sql的基础问题，如果要统计的数据（在kafka中）是那种嵌套多层的#Flink

咨询一个flink sql的基础问题，如果要统计的数据（在kafka中）是那种嵌套多层的json，能把想要的字段数据映射出来么？#Flink

flink sql没法指定并行度。那kafka数据消费不过来，怎么办 #Flink

Flink SQL Connect Kafka可以设置数据失效时间么，不然会一直append到直到内

Flink SQL Connect Kafka可以设置数据失效时间么，不然会一直append到直到内存爆炸么？

想问下为什么kafka双流join的时候，每个流的算子都能执行，但是最后用flink sql joi

想问下为什么kafka双流join的时候，每个流的算子都能执行，但是最后用flink sql join的时候没有执行sql呢?

使用Canal同步MySQL数据到Kafka 得到的数据中sql字段无值

"data": [{ "id": "13", "username": "13", "password": "6BB4837EB74329105EE4568DDA7DC67ED2CA2AD9", "name": "Canal Manager", "roles": "admin", "introduct...

Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL | 9月4号栖夜读

点击订阅云栖夜读日刊，专业的技术干货，不容错过！阿里专家原创好文 1.Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL 上周六在深圳分享了《Flink SQL 1.9.0 技术内幕和最佳实践》，会后许多小伙伴对最后演示环节的 Demo 代码非常感兴趣，迫不及待地想尝试下...

Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL

上周六在深圳分享了《Flink SQL 1.9.0 技术内幕和最佳实践》，会后许多小伙伴对最后演示环节的 Demo 代码非常感兴趣，迫不及待地想尝试下，所以写了这篇文章分享下这份代码。希望对于 Flink SQL 的初学者能有所帮助。完整分享可以观看 Meetup 视频回顾：https://dev...

如何防止kafka的spark sql在数据帧中向JSON字符串添加反斜杠

出于某种原因，我执行代码.wriestream.format（json）.option（Path）。我有json，由于某种原因，标签都有双“”。我想删除所有“”。val selectData = kafkaDF.select(($"value" cast "string"))val query = ...