[jira] [Created] (FLINK-28062) Flink SQL Upsert-Kafka can not support Flink1.14.x With Sink Buffer

["Jiangfei Liu (Jira)" <ji...@apache.org>]

Jiangfei Liu created FLINK-28062:
------------------------------------

             Summary: Flink SQL Upsert-Kafka can not support Flink1.14.x With Sink Buffer
                 Key: FLINK-28062
                 URL: https://issues.apache.org/jira/browse/FLINK-28062
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka, Table SQL / API
    Affects Versions: 1.14.4, 1.14.3, 1.14.2, 1.14.0
            Reporter: Jiangfei Liu
         Attachments: 1.13-upsert-kafka.png, 1.14-upsert-kafka.png

In Flink1.14.x，Table API，Upsert-Kafka Sink can not support with sink buffer
In Flink1.13.x，can support

I look Flink1.13.x、Flink1.14.x source code，

In Flink1.13.x，Upsert-Kafka use the class org.apache.flink.streaming.connectors.kafka.table.BufferedUpsertSinkFunction

In Flink1.14.x，Upert-Kafka use the class org.apache.flink.streaming.connectors.kafka.table.ReducingUpsertWriter

I find some diffrent with two class，please look pictures



--
This message was sent by Atlassian Jira
(v8.20.7#820007)