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/12 15:50:03 UTC
[4/5] flink git commit: [FLINK-9152] Fix error message on
BroadcastConnectedStream
[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 <al...@gmail.com>
Authored: Wed Apr 11 17:38:33 2018 -0700
Committer: Aljoscha Krettek <al...@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);