You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/16 23:15:00 UTC

[jira] [Created] (FLINK-21386) FromElements ignores returns()

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)