Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/6367#discussion_r203588835 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -959,6 +959,29 @@ class DataStream[T](stream: JavaStream[T]) { @PublicEvolving def printToErr() = stream.printToErr() + /** + * Writes a DataStream to the standard output stream (stdout). For each + * element of the DataStream the result of .toString is --- End diff -- .toString => [[AnyRef.toString()]]
---