This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 587e6770f19109cd749da48dc91ccf56fc24799c Author: Fabian Paul <[email protected]> AuthorDate: Tue Sep 14 14:29:07 2021 +0200 [hotfix][connectors/kafka] Remove unused code from KafkaDynamicSink --- .../connectors/kafka/table/KafkaDynamicSink.java | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java index 1fd9caf..a67472b 100644 --- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java +++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java @@ -27,7 +27,6 @@ import org.apache.flink.connector.base.DeliveryGuarantee; import org.apache.flink.connector.kafka.sink.KafkaSink; import org.apache.flink.connector.kafka.sink.KafkaSinkBuilder; import org.apache.flink.streaming.api.datastream.DataStreamSink; -import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer; import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner; import org.apache.flink.table.api.DataTypes; import org.apache.flink.table.connector.ChangelogMode; @@ -359,20 +358,6 @@ public class KafkaDynamicSink implements DynamicTableSink, SupportsWritingMetada return metadataKeys.size() > 0; } - private static FlinkKafkaProducer.Semantic getSemantic(DeliveryGuarantee deliveryGuarantee) { - switch (deliveryGuarantee) { - case NONE: - return FlinkKafkaProducer.Semantic.NONE; - case AT_LEAST_ONCE: - return FlinkKafkaProducer.Semantic.AT_LEAST_ONCE; - case EXACTLY_ONCE: - return FlinkKafkaProducer.Semantic.EXACTLY_ONCE; - default: - throw new IllegalStateException( - "Unsupported delivery guarantee " + deliveryGuarantee); - } - } - private RowData.FieldGetter[] getFieldGetters( List<LogicalType> physicalChildren, int[] keyProjection) { return Arrays.stream(keyProjection)
