flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: Clarify where DataStream.print() and printToErr() print to
Date Tue, 17 Apr 2018 13:24:04 GMT
Repository: flink
Updated Branches:
  refs/heads/master b005ea353 -> 518adb043


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


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/518adb04
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/518adb04
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/518adb04

Branch: refs/heads/master
Commit: 518adb0437de2d3383c4b1c744199adb6bd48dfd
Parents: b005ea3
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Tue Apr 17 15:23:12 2018 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Tue Apr 17 15:23:12 2018 +0200

----------------------------------------------------------------------
 .../org/apache/flink/streaming/api/datastream/DataStream.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/518adb04/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
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
index 7fecdb0..78ba8e4 100644
--- 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 class DataStream<T> {
 	 *
 	 * <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 class DataStream<T> {
 	 *
 	 * <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


Mime
View raw message