Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.13.0
Description
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.
Attachments
Issue Links
- links to