flink learn:学习Flink 源码

Flink学习 Flink Scala版本 卡夫卡版 1.10.0 2.11+ 0.10+ Maven 模板 : https://www.mvnjar.com/org.apache.flink/flink-quickstart-scala/jar.html 注意 : 当在idea上调试时,先将 es-shade install。然后 ignore Project:es-shade ;否则有冲突问题 Flink提交 !:1.10之后去掉 -yn ,加上会报错 1:单独资源: flink run -m yarn-cluster --yarnname _wc -p 5 -yjm 1