[FLINK-9152] Fix error message on BroadcastConnectedStream
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/179b9bce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/179b9bce Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/179b9bce Branch: refs/heads/release-1.5 Commit: 179b9bce2fcdbdfa72b4b89648c48fe084b56fe2 Parents: 24a8f51 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Wed Apr 11 17:38:33 2018 -0700 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Apr 12 08:08:32 2018 -0700 ---------------------------------------------------------------------- .../flink/streaming/api/datastream/BroadcastConnectedStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/179b9bce/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java index e5454ef..cb7d8c9 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java @@ -158,7 +158,7 @@ public class BroadcastConnectedStream<IN1, IN2> { Preconditions.checkNotNull(function); Preconditions.checkArgument(inputStream1 instanceof KeyedStream, - "A KeyedBroadcastProcessFunction can only be used with a keyed stream as the second input."); + "A KeyedBroadcastProcessFunction can only be used on a keyed stream."); TwoInputStreamOperator<IN1, IN2, OUT> operator = new CoBroadcastWithKeyedOperator<>(clean(function), broadcastStateDescriptors); @@ -209,7 +209,7 @@ public class BroadcastConnectedStream<IN1, IN2> { Preconditions.checkNotNull(function); Preconditions.checkArgument(!(inputStream1 instanceof KeyedStream), - "A BroadcastProcessFunction can only be used with a non-keyed stream as the second input."); + "A BroadcastProcessFunction can only be used on a non-keyed stream."); TwoInputStreamOperator<IN1, IN2, OUT> operator = new CoBroadcastWithNonKeyedOperator<>(clean(function), broadcastStateDescriptors);
