[FLINK-9855] Check all calls to the TypeExtractor.getBinaryOperatorReturnType()

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Won't Fix
• Fix Version/s: 1.6.0
• Component/s: API / DataStream
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 16/Jul/18 08:05
• Updated: 18/Jul/18 11:49
• Resolved: 18/Jul/18 11:47

Description

KeyedStream.IntervalJoined is not calling type extraction functions correctly. It should have an index.

Other examples with potentially wrong usage are:

 - process(final BroadcastProcessFunction<IN1, IN2, OUT> function) and

 - flatMap(CoFlatMapFunction<IN1, IN2, R> coFlatMapper