windows下flink 8081页面taskmanager无输出

flink监控socket 6666端口,执行普通的wordcount程序

问题描述:

正常是下图的位置输出程序中要输出的东西

但是提交任务到8081页面后,所有输出都不在taskmanager中显示,而是显示在启动flink时弹出的java框内

图1
图2

解决

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版权协议,转载请附上原文出处链接和本声明。