This is an automated email from the ASF dual-hosted git repository.
ic4y pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new ed5eadcf73 [Hotfix] Fix com.google.common.base.Preconditions to
seatunnel shade one (#5284)
ed5eadcf73 is described below
commit ed5eadcf73b81af7e08461eeeef80ae09d807635
Author: Eric <[email protected]>
AuthorDate: Tue Aug 15 16:54:05 2023 +0800
[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one
(#5284)
---
.../src/main/java/org/apache/seatunnel/api/configuration/Options.java | 2 +-
.../java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java | 2 +-
.../connectors/cdc/base/source/enumerator/splitter/ChunkRange.java | 2 +-
.../connectors/seatunnel/cdc/mysql/config/ServerIdRange.java | 2 +-
.../clickhouse/sink/client/executor/FieldNamedPreparedStatement.java | 4 ++--
.../connectors/seatunnel/common/source/AbstractSingleSplitSource.java | 2 +-
.../connectors/seatunnel/file/sink/config/FileSinkConfig.java | 2 +-
.../seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java | 2 +-
.../seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java | 4 ++--
.../seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java | 2 +-
.../iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java | 2 +-
.../seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java | 4 ++--
.../connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java | 4 ++--
.../seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java | 4 ++--
.../jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java | 4 ++--
.../seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java | 4 ++--
.../jdbc/internal/split/JdbcNumericBetweenParametersProvider.java | 4 ++--
.../connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java | 2 +-
.../seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java | 2 +-
.../connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java | 4 ++--
.../seatunnel/mongodb/source/config/MongodbReadOptions.java | 2 +-
.../pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java | 2 +-
.../connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java | 2 +-
.../seatunnel/starrocks/client/source/StarRocksRowBatchReader.java | 2 +-
.../java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java | 2 +-
.../seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java | 2 +-
.../seatunnel/engine/common/config/server/CheckpointConfig.java | 2 +-
.../seatunnel/engine/core/dag/actions/ShufflePartitionStrategy.java | 2 +-
.../org/apache/seatunnel/engine/server/checkpoint/TaskStatistics.java | 4 ++--
.../seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java | 2 +-
.../seatunnel/engine/server/dag/execution/PipelineGenerator.java | 2 +-
.../engine/server/resourcemanager/resource/ResourceProfile.java | 2 +-
32 files changed, 42 insertions(+), 42 deletions(-)
diff --git
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java
index a4ce408d73..72057aef5f 100644
---
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java
+++
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java
@@ -30,7 +30,7 @@ import java.time.Duration;
import java.util.List;
import java.util.Map;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class Options {
diff --git
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java
index 6bf0a2a865..4eedb2255a 100644
---
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java
+++
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRowType.java
@@ -20,7 +20,7 @@ package org.apache.seatunnel.api.table.type;
import java.util.Arrays;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class SeaTunnelRowType implements CompositeType<SeaTunnelRow> {
private static final long serialVersionUID = 2L;
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/ChunkRange.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/ChunkRange.java
index 1cf62f3448..c543bad18c 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/ChunkRange.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/ChunkRange.java
@@ -22,7 +22,7 @@ import lombok.Getter;
import java.util.Objects;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* An internal structure describes a chunk range with a chunk start
(inclusive) and chunk end
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/config/ServerIdRange.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/config/ServerIdRange.java
index c3319f8a8e..a012cf4c4b 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/config/ServerIdRange.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/config/ServerIdRange.java
@@ -21,7 +21,7 @@ import
org.apache.seatunnel.connectors.cdc.base.option.JdbcSourceOptions;
import java.io.Serializable;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* This class defines a range of server id. The boundaries of the range are
inclusive.
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/FieldNamedPreparedStatement.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/FieldNamedPreparedStatement.java
index 58c7ce650b..5fa82e8c59 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/FieldNamedPreparedStatement.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/FieldNamedPreparedStatement.java
@@ -46,8 +46,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
@RequiredArgsConstructor
public class FieldNamedPreparedStatement implements PreparedStatement {
diff --git
a/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java
b/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java
index fb4c5c8527..360e8601a2 100644
---
a/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java
+++
b/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java
@@ -23,7 +23,7 @@ import org.apache.seatunnel.api.source.SeaTunnelSource;
import org.apache.seatunnel.api.source.SourceReader;
import org.apache.seatunnel.api.source.SourceSplitEnumerator;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public abstract class AbstractSingleSplitSource<T>
implements SeaTunnelSource<T, SingleSplit, SingleSplitEnumeratorState>
{
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java
index 021fb59ba8..87b005fec6 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java
@@ -40,7 +40,7 @@ import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Data
public class FileSinkConfig extends BaseFileSinkConfig implements
PartitionConfig {
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java
index eb28263937..554dd0bd75 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java
@@ -31,7 +31,7 @@ import java.io.Closeable;
import java.io.IOException;
import java.io.Serializable;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class IcebergTableLoader implements Closeable, Serializable {
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java
index b82d21a706..ac9f8c12bb 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/CommonConfig.java
@@ -28,10 +28,10 @@ import lombok.ToString;
import java.io.Serializable;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
import static
org.apache.seatunnel.connectors.seatunnel.iceberg.config.IcebergCatalogType.HADOOP;
import static
org.apache.seatunnel.connectors.seatunnel.iceberg.config.IcebergCatalogType.HIVE;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
@Getter
@ToString
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java
index 7889376e40..246aa7dd14 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java
@@ -53,7 +53,7 @@ import lombok.SneakyThrows;
import java.util.ArrayList;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@AutoService(SeaTunnelSource.class)
public class IcebergSource
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java
index b986702b76..4a084d73a5 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanSplitPlanner.java
@@ -43,7 +43,7 @@ import java.util.Collections;
import java.util.List;
import java.util.Optional;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Slf4j
public class IcebergScanSplitPlanner {
diff --git
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java
index bc9810e7f1..9a7b7a112d 100644
---
a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java
+++
b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SinkConfig.java
@@ -30,8 +30,8 @@ import lombok.ToString;
import java.time.ZoneId;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
@Setter
@Getter
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java
index ee108ad5e7..22752ba501 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java
@@ -50,8 +50,8 @@ import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
public abstract class AbstractJdbcCatalog implements Catalog {
private static final Logger LOG =
LoggerFactory.getLogger(AbstractJdbcCatalog.class);
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java
index cec934bcb0..608062fc99 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java
@@ -35,8 +35,8 @@ import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
public class MysqlCreateTableSqlBuilder {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java
index cf100075ad..0bec148b37 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java
@@ -35,8 +35,8 @@ import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
public class SqlServerCreateTableSqlBuilder {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java
index b8ba7e2fe1..29c98c7938 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java
@@ -47,8 +47,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
@RequiredArgsConstructor
@Slf4j
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcNumericBetweenParametersProvider.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcNumericBetweenParametersProvider.java
index ced1d2831f..4bf8834f6d 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcNumericBetweenParametersProvider.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/split/JdbcNumericBetweenParametersProvider.java
@@ -21,8 +21,8 @@ import java.io.Serializable;
import java.math.BigDecimal;
import java.math.RoundingMode;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkState;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkState;
/**
* This query parameters generator is an helper class to parameterize from/to
queries on a numeric
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java
index 39c72267c6..578b5de808 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/SemanticXidGenerator.java
@@ -25,7 +25,7 @@ import javax.transaction.xa.Xid;
import java.security.SecureRandom;
import java.util.Arrays;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* Generates {@link Xid} from:
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java
index 299ba28cdb..05dbe6d3c9 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XidImpl.java
@@ -26,7 +26,7 @@ import java.io.Serializable;
import java.util.Arrays;
import java.util.Objects;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* A simple {@link Xid} implementation that stores branch and global
transaction identifiers as byte
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java
index 60861891b5..74a9bd97bf 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcExactlyOnceSinkWriter.java
@@ -50,8 +50,8 @@ import java.util.Collections;
import java.util.List;
import java.util.Optional;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkState;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkState;
public class JdbcExactlyOnceSinkWriter implements SinkWriter<SeaTunnelRow,
XidInfo, JdbcSinkState> {
private static final Logger LOG =
LoggerFactory.getLogger(JdbcExactlyOnceSinkWriter.class);
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
index f0020eb41a..faffe15bc3 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/config/MongodbReadOptions.java
@@ -22,10 +22,10 @@ import lombok.Getter;
import java.io.Serializable;
-import static com.google.common.base.Preconditions.checkArgument;
import static
org.apache.seatunnel.connectors.seatunnel.mongodb.config.MongodbConfig.CURSOR_NO_TIMEOUT;
import static
org.apache.seatunnel.connectors.seatunnel.mongodb.config.MongodbConfig.FETCH_SIZE;
import static
org.apache.seatunnel.connectors.seatunnel.mongodb.config.MongodbConfig.MAX_TIME_MIN;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/** The configuration class for MongoDB source. */
@EqualsAndHashCode
diff --git
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java
index b70c8a540a..c539f7102d 100644
---
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java
+++
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java
@@ -24,7 +24,7 @@ import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.impl.MessageIdImpl;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/** This cursor would left pulsar start consuming from a specific message id.
*/
public class MessageIdStartCursor implements StartCursor {
diff --git
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java
index 7bf308b1ca..097dfa5b24 100644
---
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java
+++
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java
@@ -60,7 +60,7 @@ import java.util.Map;
import java.util.Optional;
import java.util.Set;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class StarRocksCatalog implements Catalog {
diff --git
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksRowBatchReader.java
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksRowBatchReader.java
index 4a19270589..2ea7e98c7e 100644
---
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksRowBatchReader.java
+++
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksRowBatchReader.java
@@ -50,7 +50,7 @@ import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Slf4j
public class StarRocksRowBatchReader {
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
index f7571968e8..e213bbb7e7 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
@@ -50,7 +50,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* Cluster fault tolerance test. Test the job recovery capability and data
consistency assurance
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
index e99940defe..f60a5374fb 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
@@ -48,7 +48,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
/**
* Cluster fault tolerance test. Test the job which have two pipelines can
recovery capability and
diff --git
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/CheckpointConfig.java
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/CheckpointConfig.java
index 8d521f2b8b..83bd9ba335 100644
---
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/CheckpointConfig.java
+++
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/CheckpointConfig.java
@@ -21,7 +21,7 @@ import lombok.Data;
import java.io.Serializable;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Data
@SuppressWarnings("checkstyle:MagicNumber")
diff --git
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/ShufflePartitionStrategy.java
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/ShufflePartitionStrategy.java
index 4b69eba227..45144d210f 100644
---
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/ShufflePartitionStrategy.java
+++
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/ShufflePartitionStrategy.java
@@ -35,7 +35,7 @@ import java.util.concurrent.ThreadLocalRandom;
import java.util.stream.Collectors;
import java.util.stream.Stream;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Slf4j
@SuperBuilder
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/TaskStatistics.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/TaskStatistics.java
index 03e55339d4..3b00db5546 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/TaskStatistics.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/TaskStatistics.java
@@ -21,8 +21,8 @@ import java.io.Serializable;
import java.util.Arrays;
import java.util.List;
-import static com.google.common.base.Preconditions.checkArgument;
-import static com.google.common.base.Preconditions.checkNotNull;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
public class TaskStatistics implements Serializable {
/** ID of the task the statistics belong to. */
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java
index de7c1fcb25..d7beaf3a32 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java
@@ -54,7 +54,7 @@ import java.util.Map;
import java.util.Optional;
import java.util.Set;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Slf4j
public class ExecutionPlanGenerator {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java
index 17bd2509a8..f0a92a6691 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java
@@ -29,7 +29,7 @@ import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class PipelineGenerator {
/** The action & vertex ID needs to be regenerated because of split
pipeline. */
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/resource/ResourceProfile.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/resource/ResourceProfile.java
index bc0734028b..247c1940d8 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/resource/ResourceProfile.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/resource/ResourceProfile.java
@@ -19,7 +19,7 @@ package
org.apache.seatunnel.engine.server.resourcemanager.resource;
import java.io.Serializable;
-import static com.google.common.base.Preconditions.checkArgument;
+import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
public class ResourceProfile implements Serializable {
