[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292839#comment-17292839
]
Kezhu Wang commented on FLINK-21386:
------------------------------------
[~chesnay] It works for function also, I have verified that.
{{AbstractUdfStreamOperator}} will redirect {{setOutputType}} to its
{{userFunction}}. I also planed to write a test in {{StreamGraphGeneratorTest}}
to assert this, there are tests for operators already. I just pushed a preview
[branch|https://github.com/kezhuw/flink/commit/a48df8a13ae75da954bd3cbbdf1ffc68c7ae135c#diff-8a1048680bd7aefdaf6d1007f9065b4f85a04c8a8ff9e936ad202b979df0874fR212]
if you are unsure with this.
> FromElements ignores returns()
> ------------------------------
>
> Key: FLINK-21386
> URL: https://issues.apache.org/jira/browse/FLINK-21386
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.13.0
> Reporter: Chesnay Schepler
> Priority: Critical
> Labels: usability
> Fix For: 1.13.0
>
>
> StreamExEnv#fromElements eagerly serializes data with the automatically
> determined serializer. This can result in errors for example when generic
> avro records are used, because it will default to Kryo.
> Subsequent calls to returns() have no effect because the typeinformation is
> never forwarded to the function.
> Annoyingly the fact that it serializes data isn't logged anywhere. and there
> doesn't seem to be a way to change the serializer except by using
> fromCollection() instead.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
