[FLINK-20007] SinkTransformationTranslator fail to handle the PartitionTransformation

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.0
• Component/s: API / DataStream, Connectors / Common
• Labels: pull-request-available
• Assignee: Guowei Ma
• Reporter: Guowei Ma
• Created: 05/Nov/20 16:37
• Updated: 05/Nov/20 22:46
• Resolved: 05/Nov/20 22:46

Description

In current version `SinkTransformationTranslator` connects the `SinkWriter` with a `PartitionerTransformation` if the input transformation of `SinkTransformation` is `PartitionTransformation`. This would lead to `NullPointExcetion`.

 

Actually `SinkTransformationTranslator` should connect the `Writer` to the real upstream node if input of the `SinkTransformation` is `PartitionTransformation`.  

Issue Links

• links to: GitHub Pull Request #13952