[ https://issues.apache.org/jira/browse/FLINK-20007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-20007: ----------------------------------- Labels: pull-request-available (was: ) > SinkTransformationTranslator fail to handle the PartitionTransformation > ----------------------------------------------------------------------- > > Key: FLINK-20007 > URL: https://issues.apache.org/jira/browse/FLINK-20007 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream > Reporter: Guowei Ma > Priority: Major > Labels: pull-request-available > > 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`. -- This message was sent by Atlassian Jira (v8.3.4#803005)