flink之idea篇
目录
(1)明智一
在idea等开发工具中运行代码的时候,需要把依赖配置项中的scope属性注释掉.在编译打jar包的时候,需要开启scope属性,这样最终的jar包就不会把这些依赖包也含进去,因为集群本身是有Flink的相关依赖的.
(2)明智二
自定义source
要继承自org.apache.flink.streaming.api.functions.source.SourceFunction,可先看接口源码，里面注释写的也很清楚。
一般用org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction这个继承了上面SourceFunction和RichFunction的接口。
