[jira] [Commented] (FLINK-14757) scala.StreamExecutionEnvironment Doesn't set return type upon adding source

["Aljoscha Krettek (Jira)" <ji...@apache.org>]

    [ 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)