Github user tison1 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6367#discussion_r203644208
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java
---
@@ -40,6 +40,8 @@
private boole
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:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6367
[FLINK-9850] Add a string to the print method to identify output for
DataStream
## What is the purpose of the change
*This pull request adds a string to the print method to identify output
