Aljoscha Krettek created FLINK-2551:
---------------------------------------
Summary: Fix Several Bugs in Input/Output Formats
Key: FLINK-2551
URL:
https://issues.apache.org/jira/browse/FLINK-2551 Project: Flink
Issue Type: Bug
Affects Versions: 0.9
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
This is a collection of several things that are wrong (or possibly problematic) in the handling of Input/Output formats.
The things I have so far:
- TypeSerializerInputFormat was changed to take a TypeInformation instead of a TypeSerialzer. The javadoc is not updated, however
- This lead to another bug: When the serializer is created from the TypeInformation it is not given the correct ExecutionConfig from the ExecutionEnvironment and thus custom serializers don't work. (This one, I broke)
- In BinaryOutputFormat some fields are not declared transient even though they should be
- The Streaming API does not call {{setInputType}} if a format implements {{InputTypeConfigurable}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)