Clarify where DataStream.print() and printToErr() print to

deepfield · Apr 17, 2018 · 518adb0 · 518adb0
1 parent b005ea3
commit 518adb0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -932,6 +932,9 @@ public SingleOutputStreamOperator<T> assignTimestampsAndWatermarks(
  *
  * <p>For each element of the DataStream the result of {@link Object#toString()} is written.
  *
+ * <p>NOTE: This will print to stdout on the machine where the code is executed, i.e. the Flink
+ * worker.
+ *
  * @return The closed DataStream.
  */
  @PublicEvolving
@@ -945,6 +948,9 @@ public DataStreamSink<T> print() {
  *
  * <p>For each element of the DataStream the result of {@link Object#toString()} is written.
  *
+ * <p>NOTE: This will print to stderr on the machine where the code is executed, i.e. the Flink
+ * worker.
+ *
  * @return The closed DataStream.
  */
  @PublicEvolving