将java.sql.Date的o实例转化成LocalDate类型

Author: baisui1981

tis-incr/tis-flink-cdc-mysql-plugin/src/main/java/com/qlangtech/tis/plugins/incr/flink/cdc/mysql/FlinkCDCMySQLSourceFactory.java

@@ -52,6 +52,7 @@
 import org.apache.flink.table.api.ValidationException;
 
 import java.util.List;
+import java.util.Objects;
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
@@ -77,7 +78,8 @@ public class FlinkCDCMySQLSourceFactory extends MQListenerFactory {
     @Override
     public IFlinkColCreator<FlinkCol> createFlinkColCreator(DataSourceMeta sourceMeta) {
         final IFlinkColCreator flinkColCreator = (meta, colIndex) -> {
-            return meta.getType().accept(new MySQLCDCTypeVisitor(meta, colIndex));
+            return Objects.requireNonNull(meta.getType(), "col:" + meta.getName() + " relevant type can not be null") //
+                    .accept(new MySQLCDCTypeVisitor(meta, colIndex));
         };
         return flinkColCreator;
     }

tis-incr/tis-flink-extends/src/main/java/com/qlangtech/plugins/incr/flink/cdc/FlinkCol.java

@@ -268,6 +268,9 @@ public Object apply(Object o) {
                 // com.qlangtech.plugins.incr.flink.cdc.valconvert.DateTimeConverter
                 return LocalDate.parse((String) o, dateFormatter);
             }
+            if(o instanceof java.sql.Date){
+                return ((java.sql.Date) o).toLocalDate();
+            }
             return (LocalDate) o;
         }
 

tis-transformer/src/main/java/com/qlangtech/tis/plugin/datax/transformer/impl/joiner/JoinerSelectDataSource.java

@@ -11,6 +11,7 @@
 import com.qlangtech.tis.plugin.ds.TableNotFoundException;
 import com.qlangtech.tis.sql.parser.tuple.creator.EntityName;
 
+import java.io.Serializable;
 import java.util.List;
 import java.util.Optional;
 
@@ -19,7 +20,7 @@
  * @author 百岁 (baisui@qlangtech.com)
  * @date 2026/1/13
  */
-public class JoinerSelectDataSource extends OneStepOfMultiSteps {
+public class JoinerSelectDataSource extends OneStepOfMultiSteps implements Serializable {
     @FormField(ordinal = 0, type = FormFieldType.ENUM, validate = {Validator.require})
     public String dbName;
 

tis-transformer/src/main/java/com/qlangtech/tis/plugin/datax/transformer/impl/joiner/JoinerSelectTable.java

@@ -12,6 +12,7 @@
 import com.qlangtech.tis.plugin.table.join.TableJoinMatchConditionCreatorFactory;
 import com.qlangtech.tis.util.IPluginContext;
 
+import java.io.Serializable;
 import java.util.List;
 import java.util.Optional;
 import java.util.stream.Collectors;
@@ -21,7 +22,7 @@
  * @author 百岁 (baisui@qlangtech.com)
  * @date 2026/1/13
  */
-public class JoinerSelectTable extends OneStepOfMultiSteps {
+public class JoinerSelectTable extends OneStepOfMultiSteps implements Serializable {
 
     @FormField(ordinal = 0, type = FormFieldType.ENUM, validate = {Validator.require})
     public String tagetTable;

tis-transformer/src/main/java/com/qlangtech/tis/plugin/datax/transformer/impl/joiner/JoinerSetMatchConditionAndCols.java

@@ -12,6 +12,7 @@
 import com.qlangtech.tis.plugin.table.join.TableJoinMatchConditionCreatorFactory;
 import com.qlangtech.tis.util.IPluginContext;
 
+import java.io.Serializable;
 import java.util.Collections;
 import java.util.List;
 import java.util.Optional;
@@ -21,7 +22,7 @@
  * @author 百岁 (baisui@qlangtech.com)
  * @date 2026/1/13
  */
-public class JoinerSetMatchConditionAndCols extends OneStepOfMultiSteps {
+public class JoinerSetMatchConditionAndCols extends OneStepOfMultiSteps implements Serializable {
 
     /**
      * 定义join match 规则，例如：source.order_id = target.order_id，可以定义多个关联条件

tis-transformer/src/main/java/com/qlangtech/tis/plugin/datax/transformer/impl/joiner/TargetRowsCache.java

@@ -6,6 +6,7 @@
 import com.qlangtech.tis.extension.Descriptor;
 import com.qlangtech.tis.plugin.datax.transformer.UDFDesc;
 
+import java.io.Serializable;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Objects;
@@ -18,7 +19,7 @@
  * @date 2026/1/15
  * @see JoinerSetMatchConditionAndCols
  */
-public abstract class TargetRowsCache implements Describable<TargetRowsCache> {
+public abstract class TargetRowsCache implements Describable<TargetRowsCache>, Serializable {
     public abstract boolean isOn();
 
     public abstract List<UDFDesc> getUDFDesc();