[
https://issues.apache.org/jira/browse/FLINK-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978666#comment-16978666
]
Tim Bess edited comment on FLINK-14757 at 11/20/19 7:01 PM:
------------------------------------------------------------
I probably won't be able to post a stack trace since I ran into the issue at
work, but essentially we were using Flink 1.8.1 successfully, then upgraded to
1.9.1 and the same exact code broke on the `map` after adding the source since
StreamExecutionEnvironment.java [fails to extract the type info on line
1485|https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java#L1485].
I'm assuming that line has always failed due to type erasure issues, but
continued to work since it was overwriting the type info to the correct value
using the Scala implicit using the `returns` call.
was (Author: tdbgamer):
I probably won't be able to post a stack trace since I ran into the issue at
work, but essentially we were using Flink 1.8.1 successfully, then upgraded to
1.9.1 and the same exact code broke on the `map` after adding the source since
StreamExecutionEnvironment.java [fails to extract the type info on line
1485|https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java#L1485].
I'm assuming that line has always failed due to type erasure issues, but
continued to work since it was overwriting the type info to the correct value
using the Scala implicit.
> 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)
