[FLINK-2551] Fix Several Bugs in Input/Output Formats

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9
• Component/s: API / DataSet, Runtime / Task
• Assignee: Nick Dimiduk
• Reporter: Aljoscha Krettek
• Created: 20/Aug/15 09:43
• Updated: 27/Feb/19 19:45
• Resolved: 27/Feb/19 19:45

Description

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.

Sub-Tasks

• The Streaming API does not call setInputType if a format implements InputTypeConfigurable: Closed