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

演示代码已经开源到了 GitHub 上:https://github.com/wuchong/flink-sql-submit
<https://yq.aliyun.com/go/articleRenderRedirect?url=https%3A%2F%2Fgithub.com%2Fwuchong%2Fflink-sql-submit>

这份代码主要由两部分组成:1) 能用来提交 SQL 文件的 SqlSubmit 实现。2) 用于演示的 SQL 示例、Kafka 启动停止脚本、
一份测试数据集、Kafka 数据源生成器。

通过本实战,你将学到:

* 如何使用 Blink Planner
* 一个简单的 S