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:26 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.5 fc58f9871 -> c7e915fe7


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/c7e915fe
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c7e915fe
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c7e915fe

Branch: refs/heads/release-1.5
Commit: c7e915fe72598a01deb6d630a7cc14baebc9e350
Parents: fc58f98
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:24:14 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/c7e915fe/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