[FLINK-9152] Fix error message on BroadcastConnectedStream

deepfield · Apr 12, 2018 · 48d05f1 · 48d05f1
1 parent 0838bbe
commit 48d05f1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ava/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java b/...ava/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java
@@ -158,7 +158,7 @@ public <KS, OUT> SingleOutputStreamOperator<OUT> process(
 
  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 <OUT> SingleOutputStreamOperator<OUT> process(
 
  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);