[FLINK-17950] Broken Scala env.countinuousSource method

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: API / Scala
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 26/May/20 20:14
• Updated: 27/May/20 20:19
• Resolved: 27/May/20 20:19

Description

The Scala StreamExecutionEnvironment.countinuousSource(...) method has two critical problems:

• Its return type is Unit instead of DataStream, so that no one can use the created stream
• It does not forward the TypeInformation identified by the ScalaCompiler but relies on the Java TypeExtraction stack, which cannot handle most Scala types.