From e62d2cd5586ae84f2ba425b9efde158a45edfaff Mon Sep 17 00:00:00 2001
From: hantmac <hantmac@outlook.com>
Date: Thu, 12 Oct 2023 13:57:15 +0800
Subject: [PATCH] fix: DatabendRowConverter is not serializable

---
 .../converter/DatabendRowConverter.java       | 25 +++++++------------
 1 file changed, 9 insertions(+), 16 deletions(-)

diff --git a/src/main/java/org/apache/flink/connector/databend/internal/converter/DatabendRowConverter.java b/src/main/java/org/apache/flink/connector/databend/internal/converter/DatabendRowConverter.java
index 3080646..679ac8f 100644
--- a/src/main/java/org/apache/flink/connector/databend/internal/converter/DatabendRowConverter.java
+++ b/src/main/java/org/apache/flink/connector/databend/internal/converter/DatabendRowConverter.java
@@ -1,30 +1,23 @@
 package org.apache.flink.connector.databend.internal.converter;
 
-import static org.apache.flink.connector.databend.internal.converter.DatabendConverterUtils.BOOL_TRUE;
-import static org.apache.flink.connector.databend.util.DatabendUtil.toEpochDayOneTimestamp;
-
 import com.databend.jdbc.DatabendPreparedStatement;
 import com.databend.jdbc.DatabendResultSet;
+import org.apache.flink.table.data.*;
+import org.apache.flink.table.types.logical.*;
+import org.apache.flink.table.types.logical.RowType.RowField;
+import org.apache.flink.util.Preconditions;
+
 import java.io.Serializable;
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.sql.*;
 import java.time.LocalDate;
 import java.time.LocalTime;
-import org.apache.flink.table.data.DecimalData;
-import org.apache.flink.table.data.GenericRowData;
-import org.apache.flink.table.data.RowData;
-import org.apache.flink.table.data.StringData;
-import org.apache.flink.table.data.TimestampData;
-import org.apache.flink.table.types.logical.DecimalType;
-import org.apache.flink.table.types.logical.LocalZonedTimestampType;
-import org.apache.flink.table.types.logical.LogicalType;
-import org.apache.flink.table.types.logical.RowType;
-import org.apache.flink.table.types.logical.RowType.RowField;
-import org.apache.flink.table.types.logical.TimestampType;
-import org.apache.flink.util.Preconditions;
 
-public class DatabendRowConverter {
+import static org.apache.flink.connector.databend.internal.converter.DatabendConverterUtils.BOOL_TRUE;
+import static org.apache.flink.connector.databend.util.DatabendUtil.toEpochDayOneTimestamp;
+
+public class DatabendRowConverter implements Serializable{
     private static final long serialVersionUID = 1L;
 
     private final RowType rowType;