[FLINK-8680] [data stream api] Assign meaningful names to the sinks that print to std. out and std. err.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/21491b27 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/21491b27 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/21491b27 Branch: refs/heads/master Commit: 21491b2717e3a60e63dcf4fb0aa839b9885be67a Parents: 4be3a9c Author: Stephan Ewen <[email protected]> Authored: Fri Feb 16 20:21:07 2018 +0100 Committer: Stephan Ewen <[email protected]> Committed: Sun Feb 18 22:24:35 2018 +0100 ---------------------------------------------------------------------- .../org/apache/flink/streaming/api/datastream/DataStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/21491b27/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 9a17987..a357eda 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 @@ -942,7 +942,7 @@ public class DataStream<T> { @PublicEvolving public DataStreamSink<T> print() { PrintSinkFunction<T> printFunction = new PrintSinkFunction<>(); - return addSink(printFunction); + return addSink(printFunction).name("Print to Std. Out"); } /** @@ -955,7 +955,7 @@ public class DataStream<T> { @PublicEvolving public DataStreamSink<T> printToErr() { PrintSinkFunction<T> printFunction = new PrintSinkFunction<>(true); - return addSink(printFunction); + return addSink(printFunction).name("Print to Std. Err"); } /**
