[
https://issues.apache.org/jira/browse/FLINK-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977342#comment-16977342
]
Aljoscha Krettek commented on FLINK-14757:
------------------------------------------
This change should actually still set the output type because we now pass the
type directly in the function call which also sets it on the transformer? Could
you maybe step through the code using a debugger and see if (or why not) the
output type is set or not set.
Could you post a stacktrace or an example to show how this fails for you?
> 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.0, 1.9.1
> Reporter: Tim Bess
> Priority: Major
>
> [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)
