flink监控socket 6666端口,执行普通的wordcount程序
问题描述:
正常是下图的位置输出程序中要输出的东西
但是提交任务到8081页面后,所有输出都不在taskmanager中显示,而是显示在启动flink时弹出的java框内


解决
windows搭建flink,在cmd启动flink的时候,会弹出两个cmd框,使用jps查看新增的进程有:
3328 TaskManagerRunner
8800 StandaloneSessionClusterEntrypoint
由此可知,确实输出到TaskManager里了,但是是输出到cmd的TaskManager里,而不是网页上TaskManager的stdout里
代码
package xx
import org.apache.flink.streaming.api.scala._
object streamWordCount {
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
val streamData = env.socketTextStream("localhost",6666) //监听socket的6666端口
val resultData = streamData.flatMap(_.split(" ")).map((_,1))
.keyBy(0)
.sum(1)
resultData.print()
env.execute("stream word count")
}
}
版权声明:本文为u014657468原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。