Chesnay Schepler created FLINK-21386:
----------------------------------------
Summary: 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
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)
