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 2017/05/16 11:53:30 UTC
flink git commit: [hotfix] Further clarify side-output error message
for same id and type
Repository: flink
Updated Branches:
refs/heads/master 5ba5cd5ac -> 06dff8121
[hotfix] Further clarify side-output error message for same id and type
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06dff812
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06dff812
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06dff812
Branch: refs/heads/master
Commit: 06dff812132cb5796ec824f0c9dd0ac6fbc8351d
Parents: 5ba5cd5
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Tue May 16 07:52:34 2017 -0400
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Tue May 16 07:52:34 2017 -0400
----------------------------------------------------------------------
.../java/org/apache/flink/streaming/api/graph/StreamGraph.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/06dff812/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
index 2784517..4026817 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
@@ -320,8 +320,9 @@ public class StreamGraph extends StreamingPlan {
if (tag.f1.getId().equals(outputTag.getId()) &&
!tag.f1.getTypeInfo().equals(outputTag.getTypeInfo())) {
- throw new IllegalArgumentException("Trying to add a side output for the same" +
- "side-output id with a different type. This is not allowed.");
+ throw new IllegalArgumentException("Trying to add a side output for the same " +
+ "side-output id with a different type. This is not allowed. Side-output ID: " +
+ tag.f1.getId());
}
}