scala shell命令行

用于测试flink集群健康程度。

start-scala-shell.sh remote node01 8081

启动flink-scala-shell： 批计算和流计算： 启动一个流计算：

senv.socketTextStream("node01",8888).flatMap(_.split(" ")).map((_,1)).keyBy(0).sum(1).print()

但此时没有真正启动，需要调用如下命令才能真正启动：

senv.execute("first shell job")

执行上条命令之前要先开一个socket： 此时才能真正启动：