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()

但此時沒有真正啟動，需要調(diào)用如下命令才能真正啟動：

senv.execute("first shell job")

執(zhí)行上條命令之前要先開一個socket：

此時才能真正啟動：

總結(jié)

以上是生活随笔為你收集整理的flink scala shell命令行使用示例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。