diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/SQLSinkBuilder.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/SQLSinkBuilder.java index e4168f6064..b409ee169b 100644 --- a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/SQLSinkBuilder.java +++ b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/sql/SQLSinkBuilder.java @@ -43,7 +43,7 @@ import java.util.Map; import java.util.Optional; -import com.google.common.collect.Lists; +import cn.hutool.core.collection.CollUtil; public class SQLSinkBuilder extends AbstractSqlSinkBuilder implements Serializable { @@ -58,7 +58,7 @@ private SQLSinkBuilder(FlinkCDCConfig config) { @Override protected void initTypeConverterList() { - typeConverterList = Lists.newArrayList( + typeConverterList = CollUtil.newArrayList( this::convertDateType, this::convertTimestampType, this::convertFloatType,