You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2018/04/17 13:24:04 UTC
flink git commit: Clarify where DataStream.print() and printToErr()
print to
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 <al...@gmail.com>
Authored: Tue Apr 17 15:23:12 2018 +0200
Committer: Aljoscha Krettek <al...@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