flink1.12.x Table API:从socket读取数据,实现分组聚合查询(Retract)
flink1.12.x Table API 和 SQL:Catalogs 介绍
flink1.12.x Table API 和 SQL:读取csv文件,实现分组聚合查询
maven报错:java:-source1.5中不支持diamond运算符
maven 插件 maven-compiler-plugin 指定版本(maven.compiler.target、maven.compiler.source)
Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout
flink1.12.x 打包pom.xml,yarn方式运行(socket案例)
maven <dependency>中的<scope>:compile、provided、runtime
flink1.12.x flink run 执行flink程序(session cluster模式)
flink1.12.x flink run 执行flink程序(per-job cluster模式)