Tim Bess created FLINK-14757:
--------------------------------
Summary: scala.StreamExecutionEnvironment Doesn't set return type
upon adding source
Key: FLINK-14757
URL: https://issues.apache.org/jira/browse/FLINK-14757
Project: Flink
Issue Type: Bug
Components: API / Scala
Affects Versions: 1.9.1, 1.9.0
Reporter: Tim Bess
[This
line|https://github.com/apache/flink/blob/d36ce5ff77fae2b01b8fbe8e5c15d610de8ed9f5/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala#L618]
in StreamExecutionEnvironment.scala was changed to remove the `returns` call
starting in version 1.9.0. This causes subsequent transformations on the stream
to fail since the return TypeInformation isn't set anymore.
Looks like the change was made in [this
pr|https://github.com/apache/flink/pull/8914]. Guessing it was a mistake unless
there's some reason to do this that I'm not understanding.
I'm willing to make the PR to fix it, just need it changed so we can start
upgrading our microservices to 1.9.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
