Scala-Flink程序未按预期打印

Question

我从以下其中一个网站获得了代码。根据作者的说法，Scala程序应打印单词数。它没有按预期打印，也没有引发任何错误。但是，作业成功完成。成功消息同时出现在控制台和浏览器上（http://localhost:8081/#/job/completed）

非常感谢您的帮助。在此先感谢

我正在通过命令向程序提供输入

nc -lk 9000

代码

import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.windowing.time.Time

object StreamingWordCount {
  def main(args: Array[String]) {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val socketStream = env.socketTextStream("localhost",9000)
    val wordsStream = socketStream.flatMap(value => value.split("\\s+")).map(value => (value,1))
    val keyValuePair = wordsStream.keyBy(0)
    val countPair = keyValuePair.sum(1)
    countPair.print()
    env.execute()
  }
}

Answer 1

似乎您可能正在本地群集上运行此命令，在这种情况下，输出将保存在Flink日志目录的文件中。如果您在IDE中运行此程序，则打印出来的所有内容都会显示在IDE的控制台中。