[FLINK-18539] StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.10.2, 1.12.0, 1.11.1
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 09/Jul/20 09:37
• Updated: 15/Jul/20 03:56
• Resolved: 14/Jul/20 01:58

Description

class MySource<T> implements SourceFunction<T>, ResultTypeQueryable<T> {
 TypeInformation getProducedType() {
   return TypeExtractor.createTypeInfo(SourceFunction.class, this.getClass(), 0, null, null);
 } 
}

DataStream ds = tEnv.addSource(new MySource(), Types.ROW(Types.STRING))

The returned TypeInformation of MySource is GenericTypeInfo, not the user given RowTypeInfo.

It seems that StreamExecutionEnvironment#getTypeInfo doesn't use the user given typeInfo in the highest priority.

Issue Links

• links to: GitHub Pull Request #12863