Repository: flink Updated Branches: refs/heads/master 1c5a929c7 -> c80e76bd7
[hotfix] [types] Expose type extraction error for fromElements/Collection() This closes #6036. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c80e76bd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c80e76bd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c80e76bd Branch: refs/heads/master Commit: c80e76bd7ccfe864566bdbffd6dcb6549709ea73 Parents: 1c5a929 Author: Timo Walther <[email protected]> Authored: Thu May 17 17:05:39 2018 +0200 Committer: Timo Walther <[email protected]> Committed: Tue May 22 15:00:30 2018 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/ExecutionEnvironment.java | 4 ++-- .../streaming/api/environment/StreamExecutionEnvironment.java | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c80e76bd/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java b/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java index 5a5bddb..8206220 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java @@ -703,7 +703,7 @@ public abstract class ExecutionEnvironment { catch (Exception e) { throw new RuntimeException("Could not create TypeInformation for type " + data[0].getClass().getName() + "; please specify the TypeInformation manually via " - + "ExecutionEnvironment#fromElements(Collection, TypeInformation)"); + + "ExecutionEnvironment#fromElements(Collection, TypeInformation)", e); } return fromCollection(Arrays.asList(data), typeInfo, Utils.getCallLocationName()); @@ -736,7 +736,7 @@ public abstract class ExecutionEnvironment { catch (Exception e) { throw new RuntimeException("Could not create TypeInformation for type " + type.getName() + "; please specify the TypeInformation manually via " - + "ExecutionEnvironment#fromElements(Collection, TypeInformation)"); + + "ExecutionEnvironment#fromElements(Collection, TypeInformation)", e); } return fromCollection(Arrays.asList(data), typeInfo, Utils.getCallLocationName()); http://git-wip-us.apache.org/repos/asf/flink/blob/c80e76bd/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java index 83ca4a6..f35434f 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java @@ -711,7 +711,7 @@ public abstract class StreamExecutionEnvironment { catch (Exception e) { throw new RuntimeException("Could not create TypeInformation for type " + data[0].getClass().getName() + "; please specify the TypeInformation manually via " - + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)"); + + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)", e); } return fromCollection(Arrays.asList(data), typeInfo); } @@ -744,7 +744,7 @@ public abstract class StreamExecutionEnvironment { catch (Exception e) { throw new RuntimeException("Could not create TypeInformation for type " + type.getName() + "; please specify the TypeInformation manually via " - + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)"); + + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)", e); } return fromCollection(Arrays.asList(data), typeInfo); } @@ -785,7 +785,7 @@ public abstract class StreamExecutionEnvironment { catch (Exception e) { throw new RuntimeException("Could not create TypeInformation for type " + first.getClass() + "; please specify the TypeInformation manually via " - + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)"); + + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)", e); } return fromCollection(data, typeInfo); }
