[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-21386.
------------------------------------
Resolution: Fixed
Fixed in 0fc03e408cb80f37699e116230a5876dd7ff03e9
> 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
> Assignee: Kezhu Wang
> Priority: Critical
> Labels: pull-request-available, 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)
