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

Branch: refs/heads/master
Commit: 48d05f12eac28a7f66dee68e0a0b0000ff557e26
Parents: 0838bbe
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:04:30 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/48d05f12/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);

Reply via email to