Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19510 FLIP-143: Introduce a new unified sink api
  3. FLINK-20007

SinkTransformationTranslator fail to handle the PartitionTransformation

    XMLWordPrintableJSON

    Details

      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`.  

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                maguowei Guowei Ma
                Reporter:
                maguowei Guowei Ma
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: