[jira] [Created] (FLINK-20007) SinkTransformationTranslator fail to handle the PartitionTransformation

[Shang Yuanchun (Jira)]

Guowei Ma created FLINK-20007:
---------------------------------

             Summary: 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


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)