部署

守夜人部署

Mini Cluster

使用如下指令编译：

mvn clean package -pl lofka-night-watcher -am -Pmini-cluster

编译完成后将lofka-night-watcher/target下的JAR包和lib文件夹拷出来，同时确保conf文件夹下有lofka-kafka-client.properties和lofka-statistics-mongo.properties文件。

最后在文件夹下执行java -jar lofka-night-watcher-版本号.jar即可启动流计算。

此时启动的流计算中不包含动态计算内容，如果需要使用动态计算请在执行的时候加上参数：

--dynamics 动态配置地址

标准模式（Standalone Cluster 或者 YARN）

程序不需要修改即可在 Flink 1.6.2 的集群上提交，但是需要注意的是，如果你想要使得你的JAR包更小，请改用如下指令编译：

mvn clean package -pl lofka-night-watcher -am -Pcluster

同时需要注意的是，采用集群模式的时候你需要将lofka-kafka-client.properties和lofka-statistics-mongo.properties文件拷贝到resources目录中确保能正确加载。

你也可以修改代码，让程序从配置中心加载，这也是我们在内部流计算实践后的推荐做法。

同时取消<scope>runtime</scope>和<scope>provided</scope>的注释。