flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/9] flink git commit: Improved exception for missing type of InputFormat
Date Tue, 03 Feb 2015 12:23:40 GMT
Repository: flink
Updated Branches:
  refs/heads/master 94c3e9c08 -> 80646b57a


Improved exception for missing type of InputFormat

This closes #351


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2a7e40bb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2a7e40bb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2a7e40bb

Branch: refs/heads/master
Commit: 2a7e40bb73542a76c42c0d0740f1a437d3a90fc8
Parents: 215cf0c
Author: twalthr <twalthr@apache.org>
Authored: Thu Jan 29 16:44:12 2015 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Tue Feb 3 11:34:16 2015 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/api/java/ExecutionEnvironment.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/2a7e40bb/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 35d8c44..204ba29 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
@@ -395,7 +395,8 @@ public abstract class ExecutionEnvironment {
 		}
 		catch (Exception e) {
 			throw new InvalidProgramException("The type returned by the input format could not be
automatically determined. " +
-					"Please specify the TypeInformation of the produced type explicitly.");
+					"Please specify the TypeInformation of the produced type explicitly by using the " +
+					"'createInput(InputFormat, TypeInformation)' method instead.");
 		}
 	}
 	
@@ -427,7 +428,8 @@ public abstract class ExecutionEnvironment {
 		}
 		catch (Exception e) {
 			throw new InvalidProgramException("The type returned by the input format could not be
automatically determined. " +
-					"Please specify the TypeInformation of the produced type explicitly.");
+					"Please specify the TypeInformation of the produced type explicitly by using the " +
+					"'createInput(InputFormat, TypeInformation)' method instead.");
 		}
 	}
 


Mime
View raw message