scala shell命令行

用于測(cè)試flink集群健康程度。

start-scala-shell.sh remote node01 8081

啟動(dòng)flink-scala-shell：

批計(jì)算和流計(jì)算：

啟動(dòng)一個(gè)流計(jì)算：

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

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

senv.execute("first shell job")

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

此時(shí)才能真正啟動(dòng)：

總結(jié)

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

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