[FLINK-3449] createInput swallows exception if TypeExtractor fails

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.0
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 19/Feb/16 11:28
• Updated: 26/Feb/16 12:33
• Resolved: 26/Feb/16 12:33

Description

I've implemented an Inputformat that implements ResultTypeQueryable which is used with createInput(<InputFormat>).

When getProducedType() failed i only got an InvalidProgramException, and no mention of the original cause.

Exception in thread "main" org.apache.flink.api.common.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.
	at org.apache.flink.api.java.ExecutionEnvironment.createInput(ExecutionEnvironment.java:555)
	at org.apache.flink.api.java.io.jdbc.example.JDBCExample.main(JDBCExample.java:43)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)