```scala package com.gosuncn import org.apache.flink.streaming.api.scala._ object WordCountStreamingJob { def main(args: Array[String]) { val env = StreamExecutionEnvironment.getExecutionEnvironment // lines.flatMap(_.split(" ")).map((_, 1)).keyBy(0).sum(1).print() val lines: DataStream[String] = env.socketTextStream("47.52.74.183", 8888) val words: DataStream[String] = lines.flatMap(_.split(" ")) val wordAndOne: DataStream[(String, Int)] = words.map((_, 1)) val summed: DataStream[(String, Int)] = wordAndOne.keyBy(0).sum(1) summed.print() env.execute("WordCountStreamingJob") } } ```