You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/05/22 13:01:32 UTC
flink git commit: [hotfix] [types] Expose type extraction error for
fromElements/Collection()
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 <tw...@apache.org>
Authored: Thu May 17 17:05:39 2018 +0200
Committer: Timo Walther <tw...@apache.org>
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);
}