From 9c81d306c8ca2254dcf1603089d06d563831b524 Mon Sep 17 00:00:00 2001
From: zhuanglw <zhanglw@rongji.com>
Date: Mon, 23 Dec 2024 09:01:15 +0000
Subject: [PATCH] fix DynamicKafkaRecordSerializationSchema, add
 serialVersionUID

---
 .../kafka/table/DynamicKafkaRecordSerializationSchema.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java b/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java
index 229b08b5f..df76d9936 100644
--- a/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java
+++ b/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java
@@ -43,7 +43,7 @@
 /** SerializationSchema used by {@link KafkaDynamicSink} to configure a {@link KafkaSink}. */
 @Internal
 class DynamicKafkaRecordSerializationSchema implements KafkaRecordSerializationSchema<RowData> {
-
+    private static final long serialVersionUID = 1L;
     private final Set<String> topics;
     private final Pattern topicPattern;
     private final KafkaPartitioner<RowData> partitioner;