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)
