Changes to solve Serialization error

Author: Samrat002

flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/converter/RedshiftConverterUtils.java

@@ -110,4 +110,6 @@ public static Timestamp toEpochDayOneTimestamp(LocalTime localTime) {
         LocalDateTime localDateTime = localTime.atDate(LocalDate.ofEpochDay(1));
         return Timestamp.valueOf(localDateTime);
     }
+
+    private RedshiftConverterUtils() {}
 }

flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/converter/RedshiftCopyModeRowConverter.java

@@ -30,7 +30,7 @@
 public class RedshiftCopyModeRowConverter implements RedshiftRowConverter {
 
     private static final long serialVersionUID = 1L;
-    private final LogicalType[] fieldTypes;
+    private final transient LogicalType[] fieldTypes;
 
     public RedshiftCopyModeRowConverter(LogicalType[] fieldTypes) {
         this.fieldTypes = fieldTypes;

flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/converter/RedshiftJdbcModeRowConverter.java

@@ -40,9 +40,9 @@
 public class RedshiftJdbcModeRowConverter implements RedshiftRowConverter {
     private static final long serialVersionUID = 1L;
 
-    private final RowType rowType;
+    private final transient RowType rowType;
 
-    private final SerializationConverter[] toExternalConverters;
+    private final transient SerializationConverter[] toExternalConverters;
 
     public RedshiftJdbcModeRowConverter(RowType rowType) {
         this.rowType = Preconditions.checkNotNull(rowType);

flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/converter/SerializationConverter.java

@@ -21,12 +21,10 @@
 import org.apache.flink.connector.redshift.internal.statement.FieldNamedRedshiftPreparedStatement;
 import org.apache.flink.table.data.RowData;
 
-import java.io.Serializable;
 import java.sql.SQLException;
 
 @FunctionalInterface
-interface SerializationConverter extends Serializable {
-    long serialVersionUID = 1L;
+interface SerializationConverter {
     /** Convert an internal field to java object and fill into the {@link RedshiftRowConverter}. */
     void serialize(RowData rowData, int index, FieldNamedRedshiftPreparedStatement statement)
             throws SQLException;