[FLINK-3449] createInput() no longer swallows exception

This closes apache#1675
kongxi · Feb 26, 2016 · 725f746 · 725f746
1 parent 0fb6e0d
commit 725f746
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -554,7 +554,7 @@ public <X> DataSource<X> createInput(InputFormat<X, ?> inputFormat) {
  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 by using the " +
- "'createInput(InputFormat, TypeInformation)' method instead.");
+ "'createInput(InputFormat, TypeInformation)' method instead.", e);
  }
  }