This is an automated email from the ASF dual-hosted git repository.
fanjia 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 51c0d709ba [Improve][CheckStyle] Remove useless 'SuppressWarnings'
annotation of checkstyle. (#5260)
51c0d709ba is described below
commit 51c0d709ba34a2edb38b92de90ec2ec9c3ec15eb
Author: FlechazoW <[email protected]>
AuthorDate: Fri Aug 18 10:13:56 2023 +0800
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of
checkstyle. (#5260)
---
.../apache/seatunnel/api/common/metrics/ThreadSafeQPSMeter.java | 1 -
.../apache/seatunnel/api/configuration/ReadableConfigTest.java | 1 -
.../org/apache/seatunnel/common/utils/SerializationUtils.java | 1 -
.../org/apache/seatunnel/common/utils/SerializationUtilsTest.java | 1 -
.../seatunnel/amazondynamodb/config/AmazonDynamoDBConfig.java | 2 --
.../connectors/seatunnel/assertion/sink/AssertSinkWriter.java | 1 -
.../connectors/cdc/base/config/JdbcSourceConfigFactory.java | 1 -
.../seatunnel/connectors/cdc/base/option/JdbcSourceOptions.java | 1 -
.../cdc/base/relational/connection/JdbcConnectionFactory.java | 1 -
.../base/source/reader/external/JdbcSourceFetchTaskContext.java | 1 -
.../seatunnel/cdc/mysql/source/offset/BinlogOffset.java | 1 -
.../seatunnel/cdc/mysql/utils/MySqlConnectionUtils.java | 2 --
.../connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java | 1 -
.../connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java | 1 -
.../connectors/seatunnel/clickhouse/config/ClickhouseConfig.java | 1 -
.../seatunnel/clickhouse/sink/client/ClickhouseSink.java | 1 -
.../connectors/seatunnel/console/sink/ConsoleSinkWriter.java | 1 -
.../connectors/seatunnel/elasticsearch/config/SinkConfig.java | 2 --
.../connectors/seatunnel/elasticsearch/config/SourceConfig.java | 1 -
.../seatunnel/connectors/seatunnel/fake/config/FakeOption.java | 1 -
.../connectors/seatunnel/fake/utils/FakeDataRandomUtils.java | 1 -
.../connectors/seatunnel/file/sink/BaseFileSinkWriter.java | 1 -
.../seatunnel/file/sink/writer/ParquetWriteStrategy.java | 3 ---
.../connectors/seatunnel/file/source/reader/OrcReadStrategy.java | 1 -
.../connectors/seatunnel/file/writer/OrcReadStrategyTest.java | 1 -
.../connectors/seatunnel/file/writer/ParquetReadStrategyTest.java | 1 -
.../connectors/seatunnel/file/sftp/system/SFTPFileSystem.java | 1 -
.../connectors/seatunnel/influxdb/config/InfluxDBConfig.java | 1 -
.../connectors/seatunnel/influxdb/config/SinkConfig.java | 1 -
.../seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java | 1 -
.../jdbc/internal/converter/AbstractJdbcRowConverter.java | 1 -
.../seatunnel/jdbc/internal/dialect/db2/DB2TypeMapper.java | 1 -
.../seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java | 1 -
.../jdbc/internal/dialect/gbase8a/Gbase8aTypeMapper.java | 1 -
.../seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java | 1 -
.../seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java | 1 -
.../jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java | 1 -
.../jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java | 1 -
.../seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java | 1 -
.../jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java | 1 -
.../jdbc/internal/dialect/tablestore/TablestoreTypeMapper.java | 1 -
.../seatunnel/kafka/source/KafkaSourceSplitEnumerator.java | 1 -
.../connectors/seatunnel/pulsar/source/PulsarSource.java | 1 -
.../seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java | 1 -
.../seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java | 1 -
.../seatunnel/starrocks/client/source/model/QueryPlan.java | 1 -
.../connectors/seatunnel/starrocks/config/SourceConfig.java | 5 -----
.../connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java | 1 -
.../seatunnel/tdengine/typemapper/TDengineTypeMapper.java | 1 -
.../org/apache/seatunnel/core/starter/flink/FlinkStarter.java | 1 -
.../org/apache/seatunnel/core/starter/flink/FlinkStarter.java | 1 -
.../org/apache/seatunnel/core/starter/spark/SparkStarter.java | 2 --
.../org/apache/seatunnel/core/starter/spark/SparkStarter.java | 2 --
.../core/starter/seatunnel/command/ClientExecuteCommand.java | 2 --
.../java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java | 1 -
.../org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java | 1 -
.../org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java | 8 --------
.../seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java | 6 ------
.../seatunnel/engine/client/MultipleTableJobConfigParserTest.java | 2 --
.../org/apache/seatunnel/engine/client/SeaTunnelClientTest.java | 1 -
.../org/apache/seatunnel/engine/common/config/EngineConfig.java | 1 -
.../seatunnel/engine/common/config/server/CheckpointConfig.java | 1 -
.../engine/common/config/server/ServerConfigOptions.java | 1 -
.../engine/common/serializeable/ConfigDataSerializerHook.java | 2 +-
.../org/apache/seatunnel/engine/core/dag/actions/SinkAction.java | 1 -
.../seatunnel/engine/core/serializable/JobDataSerializerHook.java | 2 +-
.../org/apache/seatunnel/engine/server/CoordinatorService.java | 2 --
.../apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java | 2 --
.../java/org/apache/seatunnel/engine/server/SeaTunnelServer.java | 3 ---
.../org/apache/seatunnel/engine/server/TaskExecutionService.java | 3 ---
.../engine/server/dag/physical/PhysicalPlanGenerator.java | 1 -
.../seatunnel/engine/server/dag/physical/PhysicalVertex.java | 2 --
.../apache/seatunnel/engine/server/execution/TaskLocation.java | 2 --
.../apache/seatunnel/engine/server/master/JobHistoryService.java | 2 --
.../java/org/apache/seatunnel/engine/server/master/JobMaster.java | 2 --
.../apache/seatunnel/engine/server/persistence/FileMapStore.java | 1 -
.../engine/server/serializable/CheckpointDataSerializerHook.java | 2 +-
.../serializable/ClientToServerOperationDataSerializerHook.java | 1 -
.../org/apache/seatunnel/engine/server/task/SeaTunnelTask.java | 1 -
.../seatunnel/engine/server/task/SinkAggregatedCommitterTask.java | 1 -
.../seatunnel/engine/server/task/SourceSplitEnumeratorTask.java | 3 ---
.../engine/server/task/flow/IntermediateQueueFlowLifeCycle.java | 1 -
.../engine/server/task/group/queue/IntermediateBlockingQueue.java | 1 -
.../engine/server/task/group/queue/IntermediateDisruptor.java | 1 -
.../server/task/group/queue/disruptor/RecordEventProducer.java | 1 -
.../apache/seatunnel/engine/server/CoordinatorServiceTest.java | 1 -
.../test/java/org/apache/seatunnel/engine/server/TestUtils.java | 1 -
.../org/apache/seatunnel/engine/server/master/JobMetricsTest.java | 1 -
.../seatunnel/engine/imap/storage/file/common/WALDataUtils.java | 1 -
.../org/apache/seatunnel/format/text/TextFormatSchemaTest.java | 1 -
.../seatunnel/plugin/discovery/AbstractPluginDiscovery.java | 1 -
.../translation/flink/source/BaseSeaTunnelSourceFunction.java | 1 -
.../seatunnel/translation/flink/utils/TypeConverterUtils.java | 1 -
93 files changed, 3 insertions(+), 130 deletions(-)
diff --git
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/common/metrics/ThreadSafeQPSMeter.java
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/common/metrics/ThreadSafeQPSMeter.java
index 627e9bd4ca..11a4376d7c 100644
---
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/common/metrics/ThreadSafeQPSMeter.java
+++
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/common/metrics/ThreadSafeQPSMeter.java
@@ -48,7 +48,6 @@ public class ThreadSafeQPSMeter implements Meter,
Serializable {
VOLATILE_VALUE_UPDATER.addAndGet(this, n);
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public double getRate() {
long cost = System.currentTimeMillis() - timestamp;
diff --git
a/seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/ReadableConfigTest.java
b/seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/ReadableConfigTest.java
index b1436edd0f..ffaae72d0f 100644
---
a/seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/ReadableConfigTest.java
+++
b/seatunnel-api/src/test/java/org/apache/seatunnel/api/configuration/ReadableConfigTest.java
@@ -35,7 +35,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-@SuppressWarnings("checkstyle:StaticVariableName")
public class ReadableConfigTest {
private static final String CONFIG_PATH = "/conf/option-test.conf";
private static ReadonlyConfig config;
diff --git
a/seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationUtils.java
b/seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationUtils.java
index d0e9a5b941..46494bc5c5 100644
---
a/seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationUtils.java
+++
b/seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/SerializationUtils.java
@@ -44,7 +44,6 @@ public class SerializationUtils {
return null;
}
- @SuppressWarnings("checkstyle:MagicNumber")
public static <T extends Serializable> byte[] serialize(T obj) {
try (ByteArrayOutputStream b = new ByteArrayOutputStream(512);
ObjectOutputStream out = new ObjectOutputStream(b)) {
diff --git
a/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/SerializationUtilsTest.java
b/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/SerializationUtilsTest.java
index 8121a6b42c..b5085d85b2 100644
---
a/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/SerializationUtilsTest.java
+++
b/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/SerializationUtilsTest.java
@@ -23,7 +23,6 @@ import org.junit.jupiter.api.Test;
import java.util.ArrayList;
import java.util.HashMap;
-@SuppressWarnings("checkstyle:RegexpSingleline")
public class SerializationUtilsTest {
@Test
diff --git
a/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazonDynamoDBConfig.java
b/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazonDynamoDBConfig.java
index ccb6808ffa..5194e50f7c 100644
---
a/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazonDynamoDBConfig.java
+++
b/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazonDynamoDBConfig.java
@@ -49,14 +49,12 @@ public class AmazonDynamoDBConfig implements Serializable {
.noDefaultValue()
.withDescription("The table of Amazon DynamoDB");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> BATCH_SIZE =
Options.key("batch_size")
.intType()
.defaultValue(25)
.withDescription("The batch size of Amazon DynamoDB");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> BATCH_INTERVAL_MS =
Options.key("batch_interval_ms")
.intType()
diff --git
a/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java
b/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java
index d397681189..ee865ad9da 100644
---
a/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java
@@ -47,7 +47,6 @@ public class AssertSinkWriter extends
AbstractSinkWriter<SeaTunnelRow, Void> {
}
@Override
- @SuppressWarnings("checkstyle:RegexpSingleline")
public void write(SeaTunnelRow element) {
LONG_ACCUMULATOR.accumulate(1);
if (Objects.nonNull(assertFieldRules)) {
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java
index 068ee4be11..d5d920c257 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java
@@ -29,7 +29,6 @@ import java.util.List;
import java.util.Properties;
/** A {@link SourceConfig.Factory} to provide {@link SourceConfig} of JDBC
data source. */
-@SuppressWarnings("checkstyle:MagicNumber")
public abstract class JdbcSourceConfigFactory implements
SourceConfig.Factory<JdbcSourceConfig> {
private static final long serialVersionUID = 1L;
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/option/JdbcSourceOptions.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/option/JdbcSourceOptions.java
index 715915c745..813d69b862 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/option/JdbcSourceOptions.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/option/JdbcSourceOptions.java
@@ -25,7 +25,6 @@ import java.time.ZoneId;
import java.util.List;
/** Configurations for {@link IncrementalSource} of JDBC data source. */
-@SuppressWarnings("checkstyle:MagicNumber")
public class JdbcSourceOptions extends SourceOptions {
public static final Option<String> HOSTNAME =
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionFactory.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionFactory.java
index 5fad3f6f22..349adf37fd 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionFactory.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionFactory.java
@@ -44,7 +44,6 @@ public class JdbcConnectionFactory implements
JdbcConnection.ConnectionFactory {
this.jdbcConnectionPoolFactory = jdbcConnectionPoolFactory;
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public Connection connect(JdbcConfiguration config) throws SQLException {
final int connectRetryTimes = sourceConfig.getConnectMaxRetries();
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/external/JdbcSourceFetchTaskContext.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/external/JdbcSourceFetchTaskContext.java
index 70741aa619..025b3aafee 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/external/JdbcSourceFetchTaskContext.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/external/JdbcSourceFetchTaskContext.java
@@ -76,7 +76,6 @@ public abstract class JdbcSourceFetchTaskContext implements
FetchTask.Context {
return SourceRecordUtils.splitKeyRangeContains(key, splitStart,
splitEnd);
}
- @SuppressWarnings("checkstyle:MissingSwitchDefault")
@Override
public void rewriteOutputBuffer(
Map<Struct, SourceRecord> outputBuffer, SourceRecord changeRecord)
{
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/offset/BinlogOffset.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/offset/BinlogOffset.java
index 0d91c02fee..f94401ba34 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/offset/BinlogOffset.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/offset/BinlogOffset.java
@@ -204,7 +204,6 @@ public class BinlogOffset extends Offset {
return Long.compare(this.getRestartSkipRows(),
that.getRestartSkipRows());
}
- @SuppressWarnings("checkstyle:EqualsHashCode")
@Override
public boolean equals(Object o) {
if (this == o) {
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlConnectionUtils.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlConnectionUtils.java
index 4cf26d5a82..3a63c5d090 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlConnectionUtils.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlConnectionUtils.java
@@ -73,7 +73,6 @@ public class MySqlConnectionUtils {
}
/** Fetch earliest binlog offsets in MySql Server. */
- @SuppressWarnings("checkstyle:MagicNumber")
public static BinlogOffset earliestBinlogOffset(JdbcConnection jdbc) {
final String showMasterStmt = "SHOW MASTER LOGS";
JdbcConnection.ResultSetMapper<BinlogOffset> getCurrentBinlogOffset =
@@ -87,7 +86,6 @@ public class MySqlConnectionUtils {
}
/** Fetch current binlog offsets in MySql Server. */
- @SuppressWarnings("checkstyle:MagicNumber")
public static BinlogOffset currentBinlogOffset(JdbcConnection jdbc) {
final String showMasterStmt = "SHOW MASTER STATUS";
JdbcConnection.ResultSetMapper<BinlogOffset> getCurrentBinlogOffset =
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
index 267476b3ff..d30ba32d22 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
@@ -80,7 +80,6 @@ public class MySqlTypeUtils {
private static final String MYSQL_VARBINARY = "VARBINARY";
private static final String MYSQL_GEOMETRY = "GEOMETRY";
- @SuppressWarnings("checkstyle:MagicNumber")
public static SeaTunnelDataType<?> convertFromColumn(Column column) {
String typeName = column.typeName();
switch (typeName) {
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java
index fb00020644..3dde38b422 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java
@@ -79,7 +79,6 @@ public class MySqlUtils {
});
}
- @SuppressWarnings("checkstyle:MagicNumber")
public static long queryApproximateRowCnt(JdbcConnection jdbc, TableId
tableId)
throws SQLException {
// The statement used to get approximate row count which is less
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseConfig.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseConfig.java
index f7c8e032cc..bb0417b171 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseConfig.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseConfig.java
@@ -25,7 +25,6 @@ import java.util.Collections;
import java.util.List;
import java.util.Map;
-@SuppressWarnings("checkstyle:MagicNumber")
public class ClickhouseConfig {
/** Bulk size of clickhouse jdbc */
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java
index 360c592598..fe1b25e909 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java
@@ -79,7 +79,6 @@ public class ClickhouseSink
return "Clickhouse";
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void prepare(Config config) throws PrepareFailException {
CheckResult result =
diff --git
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java
index 422a85b40d..fc3f7f232c 100644
---
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java
@@ -59,7 +59,6 @@ public class ConsoleSinkWriter extends
AbstractSinkWriter<SeaTunnelRow, Void> {
}
@Override
- @SuppressWarnings("checkstyle:RegexpSingleline")
public void write(SeaTunnelRow element) {
String[] arr = new String[seaTunnelRowType.getTotalFields()];
SeaTunnelDataType<?>[] fieldTypes = seaTunnelRowType.getFieldTypes();
diff --git
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java
index 34899ea6e3..beccebe3c1 100644
---
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java
+++
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java
@@ -51,14 +51,12 @@ public class SinkConfig {
.withDescription(
"Delimiter for composite keys (\"_\" by default),
e.g., \"$\" would result in document `_id` \"KEY1$KEY2$KEY3\".");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> MAX_BATCH_SIZE =
Options.key("max_batch_size")
.intType()
.defaultValue(10)
.withDescription("batch bulk doc max size");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> MAX_RETRY_COUNT =
Options.key("max_retry_count")
.intType()
diff --git
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SourceConfig.java
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SourceConfig.java
index f5c885ed3b..81c32bdf15 100644
---
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SourceConfig.java
+++
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SourceConfig.java
@@ -47,7 +47,6 @@ public class SourceConfig {
.withDescription(
"Amount of time Elasticsearch will keep the search
context alive for scroll requests");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> SCROLL_SIZE =
Options.key("scroll_size")
.intType()
diff --git
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
index 34aa9069c5..d16d5c4f59 100644
---
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
+++
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
@@ -23,7 +23,6 @@ import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import java.util.List;
-@SuppressWarnings("checkstyle:MagicNumber")
public class FakeOption {
public static final Option<List<SeaTunnelRow>> ROWS =
diff --git
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/utils/FakeDataRandomUtils.java
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/utils/FakeDataRandomUtils.java
index f140eb972e..2c4449d21f 100644
---
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/utils/FakeDataRandomUtils.java
+++
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/utils/FakeDataRandomUtils.java
@@ -122,7 +122,6 @@ public class FakeDataRandomUtils {
return randomLocalDateTime().toLocalTime();
}
- @SuppressWarnings("checkstyle:MagicNumber")
public LocalDateTime randomLocalDateTime() {
int year;
int month;
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java
index 22200249f6..a72c1b45dc 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java
@@ -44,7 +44,6 @@ public class BaseFileSinkWriter implements
SinkWriter<SeaTunnelRow, FileCommitIn
protected final WriteStrategy writeStrategy;
private final FileSystemUtils fileSystemUtils;
- @SuppressWarnings("checkstyle:MagicNumber")
public BaseFileSinkWriter(
WriteStrategy writeStrategy,
HadoopConf hadoopConf,
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
index 8c2c938200..79db210616 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java
@@ -62,7 +62,6 @@ import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
-@SuppressWarnings("checkstyle:MagicNumber")
public class ParquetWriteStrategy extends AbstractWriteStrategy {
private final LinkedHashMap<String, ParquetWriter<GenericRecord>>
beingWrittenWriter;
private AvroSchemaConverter schemaConverter;
@@ -163,7 +162,6 @@ public class ParquetWriteStrategy extends
AbstractWriteStrategy {
return writer;
}
- @SuppressWarnings("checkstyle:MagicNumber")
private Object resolveObject(Object data, SeaTunnelDataType<?>
seaTunnelDataType) {
if (data == null) {
return null;
@@ -222,7 +220,6 @@ public class ParquetWriteStrategy extends
AbstractWriteStrategy {
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
public static Type seaTunnelDataType2ParquetDataType(
String fieldName, SeaTunnelDataType<?> seaTunnelDataType) {
switch (seaTunnelDataType.getSqlType()) {
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java
index d191c3a839..a4a5d27b26 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java
@@ -162,7 +162,6 @@ public class OrcReadStrategy extends AbstractReadStrategy {
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
boolean checkFileType(String path) {
try {
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java
index 5d72ae2e00..5e8eb9a2c8 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/OrcReadStrategyTest.java
@@ -93,7 +93,6 @@ public class OrcReadStrategyTest {
return rows;
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Override
public void collect(SeaTunnelRow record) {
System.out.println(record);
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java
index de1d8d9329..82e0bac741 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/test/java/org/apache/seatunnel/connectors/seatunnel/file/writer/ParquetReadStrategyTest.java
@@ -129,7 +129,6 @@ public class ParquetReadStrategyTest {
return rows;
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Override
public void collect(SeaTunnelRow record) {
System.out.println(record);
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
index 9e551278b4..555fb5bf9d 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
@@ -208,7 +208,6 @@ public class SFTPFileSystem extends FileSystem {
return fileStat;
}
- @SuppressWarnings("checkstyle:MagicNumber")
private FileStatus getFileStatus(ChannelSftp channel, LsEntry sftpFile,
Path parentPath)
throws IOException {
diff --git
a/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/InfluxDBConfig.java
b/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/InfluxDBConfig.java
index 70690bf1d1..fa43f8fa6d 100644
---
a/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/InfluxDBConfig.java
+++
b/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/InfluxDBConfig.java
@@ -28,7 +28,6 @@ import lombok.Data;
import java.io.Serializable;
@Data
-@SuppressWarnings("checkstyle:MagicNumber")
public class InfluxDBConfig implements Serializable {
public static final Option<String> USERNAME =
diff --git
a/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/SinkConfig.java
b/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/SinkConfig.java
index b5988915fc..1070815abd 100644
---
a/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/SinkConfig.java
+++
b/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/SinkConfig.java
@@ -31,7 +31,6 @@ import java.util.List;
@Setter
@Getter
@ToString
-@SuppressWarnings("checkstyle:MagicNumber")
public class SinkConfig extends InfluxDBConfig {
public SinkConfig(Config config) {
super(config);
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
index 207995d0b4..5d2254cd34 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
@@ -23,7 +23,6 @@ import org.apache.seatunnel.api.configuration.Options;
import java.math.BigDecimal;
import java.util.List;
-@SuppressWarnings("checkstyle:MagicNumber")
public interface JdbcOptions {
Option<String> URL =
Options.key("url").stringType().noDefaultValue().withDescription("url");
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java
index 07aa795994..3d20bd9562 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java
@@ -43,7 +43,6 @@ public abstract class AbstractJdbcRowConverter implements
JdbcRowConverter {
public AbstractJdbcRowConverter() {}
@Override
- @SuppressWarnings("checkstyle:Indentation")
public SeaTunnelRow toInternal(ResultSet rs, SeaTunnelRowType typeInfo)
throws SQLException {
Object[] fields = new Object[typeInfo.getTotalFields()];
for (int fieldIndex = 0; fieldIndex < typeInfo.getTotalFields();
fieldIndex++) {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2TypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2TypeMapper.java
index 06d534ea2d..7df9210276 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2TypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2TypeMapper.java
@@ -83,7 +83,6 @@ public class DB2TypeMapper implements JdbcDialectTypeMapper {
// other
private static final String DB2_XML = "XML";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java
index c9de46723f..d6d630bc91 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeMapper.java
@@ -102,7 +102,6 @@ public class DmdbTypeMapper implements
JdbcDialectTypeMapper {
public static final String DM_LONGVARBINARY = "LONGVARBINARY";
@Override
- @SuppressWarnings("checkstyle:MagicNumber")
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
String dmdbType = metadata.getColumnTypeName(colIndex).toUpperCase();
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/gbase8a/Gbase8aTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/gbase8a/Gbase8aTypeMapper.java
index 9686c3cddd..a4c598f975 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/gbase8a/Gbase8aTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/gbase8a/Gbase8aTypeMapper.java
@@ -61,7 +61,6 @@ public class Gbase8aTypeMapper implements
JdbcDialectTypeMapper {
private static final String GBASE8A_BLOB = "BLOB";
private static final String GBASE8A_TEXT = "TEXT";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java
index e2fed97da2..d1b70d83bb 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java
@@ -87,7 +87,6 @@ public class MySqlTypeMapper implements JdbcDialectTypeMapper
{
private static final String MYSQL_VARBINARY = "VARBINARY";
private static final String MYSQL_GEOMETRY = "GEOMETRY";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
index 1822484b30..c747ba08c6 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
@@ -68,7 +68,6 @@ public class OracleTypeMapper implements
JdbcDialectTypeMapper {
private static final String ORACLE_RAW = "RAW";
private static final String ORACLE_LONG_RAW = "LONG RAW";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java
index 32b72574e4..f97d363c97 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java
@@ -73,7 +73,6 @@ public class PhoenixTypeMapper implements
JdbcDialectTypeMapper {
private static final String PHOENIX_BINARY = "BINARY";
private static final String PHOENIX_VARBINARY = "VARBINARY";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java
index 2b7dc47a9e..13ace89a04 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java
@@ -43,7 +43,6 @@ public class PostgresJdbcRowConverter extends
AbstractJdbcRowConverter {
}
@Override
- @SuppressWarnings("checkstyle:Indentation")
public SeaTunnelRow toInternal(ResultSet rs, SeaTunnelRowType typeInfo)
throws SQLException {
Object[] fields = new Object[typeInfo.getTotalFields()];
for (int fieldIndex = 0; fieldIndex < typeInfo.getTotalFields();
fieldIndex++) {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java
index 6edf6dcdaa..1d82f687c1 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeMapper.java
@@ -89,7 +89,6 @@ public class PostgresTypeMapper implements
JdbcDialectTypeMapper {
private static final String PG_JSON = "json";
private static final String PG_JSONB = "jsonb";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
index 4a8978cb24..3cd04e5e05 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
@@ -73,7 +73,6 @@ public class SqlserverTypeMapper implements
JdbcDialectTypeMapper {
private static final String SQLSERVER_VARBINARY = "VARBINARY";
private static final String SQLSERVER_IMAGE = "IMAGE";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/tablestore/TablestoreTypeMapper.java
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/tablestore/TablestoreTypeMapper.java
index 2a843418d1..3dcfa41ccf 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/tablestore/TablestoreTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/tablestore/TablestoreTypeMapper.java
@@ -49,7 +49,6 @@ public class TablestoreTypeMapper implements
JdbcDialectTypeMapper {
private static final String TABLESTORE_VARBINARY = "VARBINARY";
private static final String TABLESTORE_MEDIUMBLOB = "MEDIUMBLOB";
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public SeaTunnelDataType<?> mapping(ResultSetMetaData metadata, int
colIndex)
throws SQLException {
diff --git
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java
index f1de236cfa..9ab9f92841 100644
---
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java
+++
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java
@@ -312,7 +312,6 @@ public class KafkaSourceSplitEnumerator
pendingSplit.clear();
}
- @SuppressWarnings("checkstyle:MagicNumber")
private static int getSplitOwner(TopicPartition tp, int numReaders) {
int startIndex = ((tp.topic().hashCode() * 31) & 0x7FFFFFFF) %
numReaders;
return (startIndex + tp.partition()) % numReaders;
diff --git
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java
index cf5972aa1f..ccd71d728b 100644
---
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java
+++
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java
@@ -113,7 +113,6 @@ public class PulsarSource
return PulsarConfigUtil.IDENTIFIER;
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void prepare(Config config) throws PrepareFailException {
CheckResult result =
diff --git
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java
index ddf6cb2d66..1d4f468495 100644
---
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java
+++
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java
@@ -217,7 +217,6 @@ public class PulsarSplitEnumerator
subscriptionName);
}
- @SuppressWarnings("checkstyle:MagicNumber")
static int getSplitOwner(TopicPartition tp, int numReaders) {
int startIndex = ((tp.getTopic().hashCode() * 31) & 0x7FFFFFFF) %
numReaders;
diff --git
a/seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java
b/seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java
index d933fe2e92..ce841a4bf0 100644
---
a/seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java
+++
b/seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java
@@ -77,7 +77,6 @@ public class RocketMqSourceSplitEnumerator
this.discoveryIntervalMillis = discoveryIntervalMillis;
}
- @SuppressWarnings("checkstyle:MagicNumber")
private static int getSplitOwner(MessageQueue messageQueue, int
numReaders) {
int startIndex = ((messageQueue.getQueueId() * 31) & 0x7FFFFFFF) %
numReaders;
return (startIndex + messageQueue.getQueueId()) % numReaders;
diff --git
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPlan.java
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPlan.java
index 07d5b1629f..4b11d6da45 100644
---
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPlan.java
+++
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPlan.java
@@ -33,7 +33,6 @@ public class QueryPlan implements Serializable {
private int status;
@JsonProperty("opaqued_query_plan")
- @SuppressWarnings("checkstyle:MemberName")
private String queryPlan;
private Map<String, Tablet> partitions;
diff --git
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SourceConfig.java
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SourceConfig.java
index 34b3dc6a87..10d0358a8f 100644
---
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SourceConfig.java
+++
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SourceConfig.java
@@ -46,7 +46,6 @@ public class SourceConfig extends CommonConfig {
super(nodeUrls, username, password, database, table);
}
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> MAX_RETRIES =
Options.key("max_retries")
.intType()
@@ -62,28 +61,24 @@ public class SourceConfig extends CommonConfig {
public static final Option<String> SCAN_FILTER =
Options.key("scan_filter").stringType().defaultValue("").withDescription("SQL
filter");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> SCAN_CONNECT_TIMEOUT =
Options.key("scan_connect_timeout_ms")
.intType()
.defaultValue(1000)
.withDescription("scan connect timeout");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> SCAN_BATCH_ROWS =
Options.key("scan_batch_rows")
.intType()
.defaultValue(1024)
.withDescription("scan batch rows");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> SCAN_KEEP_ALIVE_MIN =
Options.key("scan_keep_alive_min")
.intType()
.defaultValue(10)
.withDescription("Max keep alive time min");
- @SuppressWarnings("checkstyle:MagicNumber")
public static final Option<Integer> SCAN_QUERY_TIMEOUT_SEC =
Options.key("scan_query_timeout_sec")
.intType()
diff --git
a/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java
b/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java
index 34c773aef0..6a069d531a 100644
---
a/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java
+++
b/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java
@@ -81,7 +81,6 @@ public class TDengineSinkWriter extends
AbstractSinkWriter<SeaTunnelRow, Void> {
@SneakyThrows
@Override
- @SuppressWarnings("checkstyle:RegexpSingleline")
public void write(SeaTunnelRow element) {
final ArrayList<Object> tags = Lists.newArrayList();
for (int i = element.getArity() - tagsNum; i < element.getArity();
i++) {
diff --git
a/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/typemapper/TDengineTypeMapper.java
b/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/typemapper/TDengineTypeMapper.java
index c9a0751109..a32b1af021 100644
---
a/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/typemapper/TDengineTypeMapper.java
+++
b/seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/typemapper/TDengineTypeMapper.java
@@ -80,7 +80,6 @@ public class TDengineTypeMapper {
private static final String TDENGINE_VARBINARY = "VARBINARY";
private static final String TDENGINE_GEOMETRY = "GEOMETRY";
- @SuppressWarnings("checkstyle:MagicNumber")
public static SeaTunnelDataType<?> mapping(String tdengineType) {
switch (tdengineType) {
case TDENGINE_BIT:
diff --git
a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
index 078c29bbfa..5dc1d32cef 100644
---
a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
+++
b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
@@ -44,7 +44,6 @@ public class FlinkStarter implements Starter {
this.appJar = Common.appStarterDir().resolve(APP_JAR_NAME).toString();
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
public static void main(String[] args) {
FlinkStarter flinkStarter = new FlinkStarter(args);
System.out.println(String.join(" ", flinkStarter.buildCommands()));
diff --git
a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
index 2f9021c68b..7373cb58ed 100644
---
a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
+++
b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/FlinkStarter.java
@@ -44,7 +44,6 @@ public class FlinkStarter implements Starter {
this.appJar = Common.appStarterDir().resolve(APP_JAR_NAME).toString();
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
public static void main(String[] args) {
FlinkStarter flinkStarter = new FlinkStarter(args);
System.out.println(String.join(" ", flinkStarter.buildCommands()));
diff --git
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
index c187cceb6c..5e295ef804 100644
---
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
+++
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
@@ -80,7 +80,6 @@ public class SparkStarter implements Starter {
this.commandArgs = commandArgs;
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
public static void main(String[] args) throws IOException {
SparkStarter starter = getInstance(args);
List<String> command = starter.buildCommands();
@@ -260,7 +259,6 @@ public class SparkStarter implements Starter {
Common.appStarterDir().resolve(EngineType.SPARK2.getStarterJarName()).toString());
}
- @SuppressWarnings("checkstyle:Indentation")
private List<PluginIdentifier> getPluginIdentifiers(Config config,
PluginType... pluginTypes) {
return Arrays.stream(pluginTypes)
.flatMap(
diff --git
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
index 16a3dacad2..aa07f4ecde 100644
---
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
+++
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
@@ -80,7 +80,6 @@ public class SparkStarter implements Starter {
this.commandArgs = commandArgs;
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
public static void main(String[] args) throws IOException {
SparkStarter starter = getInstance(args);
List<String> command = starter.buildCommands();
@@ -260,7 +259,6 @@ public class SparkStarter implements Starter {
Common.appStarterDir().resolve(EngineType.SPARK3.getStarterJarName()).toString());
}
- @SuppressWarnings("checkstyle:Indentation")
private List<PluginIdentifier> getPluginIdentifiers(Config config,
PluginType... pluginTypes) {
return Arrays.stream(pluginTypes)
.flatMap(
diff --git
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
index 14b00540f2..449b3f5238 100644
---
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
+++
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
@@ -69,7 +69,6 @@ public class ClientExecuteCommand implements
Command<ClientCommandArgs> {
this.clientCommandArgs = clientCommandArgs;
}
- @SuppressWarnings({"checkstyle:RegexpSingleline",
"checkstyle:MagicNumber"})
@Override
public void execute() throws CommandExecuteException {
JobMetricsRunner.JobMetricsSummary jobMetricsSummary = null;
@@ -240,7 +239,6 @@ public class ClientExecuteCommand implements
Command<ClientCommandArgs> {
new SeaTunnelNodeContext(seaTunnelConfig));
}
- @SuppressWarnings("checkstyle:MagicNumber")
private String creatRandomClusterName(String namePrefix) {
Random random = new Random();
return namePrefix + "-" + random.nextInt(1000000);
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
index 922798c3de..c72eb9d5c3 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java
@@ -331,7 +331,6 @@ public class KafkaIT extends TestSuiteBase implements
TestResource {
return props;
}
- @SuppressWarnings("checkstyle:Indentation")
private void generateTestData(ProducerRecordConverter converter, int
start, int end) {
for (int i = start; i < end; i++) {
SeaTunnelRow row =
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
index f292d11201..aba0a9f2c0 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
@@ -282,7 +282,6 @@ public class RocketMqIT extends TestSuiteBase implements
TestResource {
}
@SneakyThrows
- @SuppressWarnings("checkstyle:Indentation")
private void generateTestData(
ProducerRecordConverter converter, String topic, int start, int
end) {
for (int i = start; i < end; i++) {
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 e213bbb7e7..1b547be73b 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
@@ -68,7 +68,6 @@ public class ClusterFaultToleranceIT {
public static final String DYNAMIC_TEST_PARALLELISM =
"dynamic_test_parallelism";
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testBatchJobRunOkIn2Node() throws ExecutionException,
InterruptedException {
String testCaseName = "testBatchJobRunOkIn2Node";
@@ -193,7 +192,6 @@ public class ClusterFaultToleranceIT {
return new ImmutablePair<>(targetDir, targetConfigFilePath);
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testStreamJobRunOkIn2Node() throws ExecutionException,
InterruptedException {
String testCaseName = "testStreamJobRunOkIn2Node";
@@ -286,7 +284,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testBatchJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
@@ -386,7 +383,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testStreamJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
@@ -505,7 +501,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testBatchJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
@@ -608,7 +603,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testStreamJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
@@ -736,7 +730,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testStreamJobRestoreInAllNodeDown()
throws ExecutionException, InterruptedException {
@@ -936,7 +929,6 @@ public class ClusterFaultToleranceIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
@Disabled
public void testStreamJobRestoreFromOssInAllNodeDown()
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 f60a5374fb..608871dd56 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
@@ -69,7 +69,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
public static final String DYNAMIC_TEST_PARALLELISM =
"dynamic_test_parallelism";
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineBatchJobRunOkIn2Node()
throws ExecutionException, InterruptedException {
@@ -200,7 +199,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
return new ImmutablePair<>(targetDir, targetConfigFilePath);
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineStreamJobRunOkIn2Node()
throws ExecutionException, InterruptedException {
@@ -299,7 +297,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineBatchJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
@@ -415,7 +412,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineStreamJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
@@ -544,7 +540,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineBatchJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
@@ -653,7 +648,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
}
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testTwoPipelineStreamJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
diff --git
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/MultipleTableJobConfigParserTest.java
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/MultipleTableJobConfigParserTest.java
index a806d0a962..e5faaea25c 100644
---
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/MultipleTableJobConfigParserTest.java
+++
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/MultipleTableJobConfigParserTest.java
@@ -37,7 +37,6 @@ import java.util.Set;
public class MultipleTableJobConfigParserTest {
- @SuppressWarnings("checkstyle:MagicNumber")
@Test
public void testSimpleJobParse() {
Common.setDeployMode(DeployMode.CLIENT);
@@ -58,7 +57,6 @@ public class MultipleTableJobConfigParserTest {
Assertions.assertEquals(3, actions.get(0).getParallelism());
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Test
public void testComplexJobParse() {
Common.setDeployMode(DeployMode.CLIENT);
diff --git
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
index 85aec59c27..ff39c4b2a5 100644
---
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
+++
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
@@ -56,7 +56,6 @@ import static
org.apache.seatunnel.api.common.metrics.MetricNames.SOURCE_RECEIVE
import static
org.apache.seatunnel.api.common.metrics.MetricNames.SOURCE_RECEIVED_QPS;
import static org.awaitility.Awaitility.await;
-@SuppressWarnings("checkstyle:MagicNumber")
@DisabledOnOs(OS.WINDOWS)
public class SeaTunnelClientTest {
diff --git
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java
index e162b428bb..847053a2d9 100644
---
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java
+++
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java
@@ -30,7 +30,6 @@ import static
com.hazelcast.internal.util.Preconditions.checkNotNull;
import static com.hazelcast.internal.util.Preconditions.checkPositive;
@Data
-@SuppressWarnings("checkstyle:MagicNumber")
public class EngineConfig {
private int backupCount = ServerConfigOptions.BACKUP_COUNT.defaultValue();
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 83bd9ba335..78add9c883 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
@@ -24,7 +24,6 @@ import java.io.Serializable;
import static
org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkArgument;
@Data
-@SuppressWarnings("checkstyle:MagicNumber")
public class CheckpointConfig implements Serializable {
public static final long MINIMAL_CHECKPOINT_TIME = 10;
diff --git
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java
index 486f11878e..6a0b825405 100644
---
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java
+++
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java
@@ -24,7 +24,6 @@ import org.apache.seatunnel.api.configuration.Options;
import java.util.Map;
-@SuppressWarnings("checkstyle:MagicNumber")
public class ServerConfigOptions {
public static final Option<Integer> BACKUP_COUNT =
diff --git
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/serializeable/ConfigDataSerializerHook.java
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/serializeable/ConfigDataSerializerHook.java
index 4867939d74..7c7fa9261f 100644
---
a/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/serializeable/ConfigDataSerializerHook.java
+++
b/seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/serializeable/ConfigDataSerializerHook.java
@@ -46,7 +46,7 @@ public class ConfigDataSerializerHook implements
DataSerializerHook {
}
private static class Factory implements DataSerializableFactory {
- @SuppressWarnings("checkstyle:returncount")
+
@Override
public IdentifiedDataSerializable create(int typeId) {
switch (typeId) {
diff --git
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/SinkAction.java
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/SinkAction.java
index d13087dcfc..49a7bb69c8 100644
---
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/SinkAction.java
+++
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/actions/SinkAction.java
@@ -26,7 +26,6 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Set;
-@SuppressWarnings("checkstyle:ClassTypeParameterName")
public class SinkAction<IN, StateT, CommitInfoT, AggregatedCommitInfoT>
extends AbstractAction {
private final SeaTunnelSink<IN, StateT, CommitInfoT,
AggregatedCommitInfoT> sink;
diff --git
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/serializable/JobDataSerializerHook.java
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/serializable/JobDataSerializerHook.java
index 18bdff612b..29495085a8 100644
---
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/serializable/JobDataSerializerHook.java
+++
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/serializable/JobDataSerializerHook.java
@@ -70,7 +70,7 @@ public final class JobDataSerializerHook implements
DataSerializerHook {
}
private static class Factory implements DataSerializableFactory {
- @SuppressWarnings("checkstyle:returncount")
+
@Override
public IdentifiedDataSerializable create(int typeId) {
switch (typeId) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
index 1f87218de0..5293fe8bf9 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
@@ -152,7 +152,6 @@ public class CoordinatorService {
private final EngineConfig engineConfig;
- @SuppressWarnings("checkstyle:MagicNumber")
public CoordinatorService(
@NonNull NodeEngineImpl nodeEngine,
@NonNull SeaTunnelServer seaTunnelServer,
@@ -391,7 +390,6 @@ public class CoordinatorService {
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
private void clearCoordinatorService() {
// interrupt all JobMaster
runningJobMasterMap.values().forEach(JobMaster::interrupt);
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
index b7900871e5..2adf87aa41 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
@@ -75,7 +75,6 @@ public class SeaTunnelHealthMonitor {
return format("%.2f%%", p);
}
- @SuppressWarnings("checkstyle:magicnumber")
private static String numberToUnit(long number) {
for (int i = 6; i > 0; i--) {
// 1024 is for 1024 kb is 1 MB etc
@@ -282,7 +281,6 @@ public class SeaTunnelHealthMonitor {
.append(", ");
}
- @SuppressWarnings("checkstyle:UnnecessaryParentheses")
private void renderHeap() {
sb.append("heap.memory.used=")
.append(numberToUnit(runtimeUsedMemory.read()))
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
index f75f5af8e4..56b0e5ec00 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
@@ -90,7 +90,6 @@ public class SeaTunnelServer
return slotService;
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void init(NodeEngine engine, Properties hzProperties) {
this.nodeEngine = (NodeEngineImpl) engine;
@@ -159,7 +158,6 @@ public class SeaTunnelServer
return liveOperationRegistry;
}
- @SuppressWarnings("checkstyle:MagicNumber")
public CoordinatorService getCoordinatorService() {
int retryCount = 0;
if (isMasterNode()) {
@@ -228,7 +226,6 @@ public class SeaTunnelServer
return taskState != null && ((ExecutionState) taskState).isEndState();
}
- @SuppressWarnings("checkstyle:MagicNumber")
public boolean isMasterNode() {
// must retry until the cluster have master node
try {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java
index 8f4c40f9a5..2725836f87 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java
@@ -298,7 +298,6 @@ public class TaskExecutionService implements
DynamicMetricsProvider {
return deployLocalTask(taskGroup,
Thread.currentThread().getContextClassLoader());
}
- @SuppressWarnings("checkstyle:MagicNumber")
public PassiveCompletableFuture<TaskExecutionState> deployLocalTask(
@NonNull TaskGroup taskGroup, @NonNull ClassLoader classLoader) {
CompletableFuture<TaskExecutionState> resultFuture = new
CompletableFuture<>();
@@ -378,7 +377,6 @@ public class TaskExecutionService implements
DynamicMetricsProvider {
return new PassiveCompletableFuture<>(resultFuture);
}
- @SuppressWarnings("checkstyle:MagicNumber")
private void notifyTaskStatusToMaster(
TaskGroupLocation taskGroupLocation, TaskExecutionState
taskExecutionState) {
long sleepTime = 1000;
@@ -662,7 +660,6 @@ public class TaskExecutionService implements
DynamicMetricsProvider {
private Future<?> thisTaskFuture;
private BlockingQueue<Future<?>> futureBlockingQueue;
- @SuppressWarnings("checkstyle:MagicNumber")
public CooperativeTaskWorker(
LinkedBlockingDeque<TaskTracker> taskqueue,
RunBusWorkSupplier runBusWorkSupplier,
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java
index a238ae134c..c6173cf064 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java
@@ -737,7 +737,6 @@ public class PhysicalPlanGenerator {
.contains(true);
}
- @SuppressWarnings("checkstyle:MagicNumber")
private long mixIDPrefixAndIndex(long idPrefix, int index) {
return idPrefix * 10000 + index;
}
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java
index 3c840a269a..85cc31850b 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java
@@ -295,7 +295,6 @@ public class PhysicalVertex {
});
}
- @SuppressWarnings("checkstyle:MagicNumber")
// This method must not throw an exception
public TaskDeployState deploy(@NonNull SlotProfile slotProfile) {
try {
@@ -479,7 +478,6 @@ public class PhysicalVertex {
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
private void noticeTaskExecutionServiceCancel() {
// Check whether the node exists, and whether the Task on the node
exists. If there is no
// direct update state
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskLocation.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskLocation.java
index 210a3802c3..00ee084145 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskLocation.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskLocation.java
@@ -43,7 +43,6 @@ public class TaskLocation implements
IdentifiedDataSerializable, Serializable {
this.index = index;
}
- @SuppressWarnings("checkstyle:MagicNumber")
private long mixIDPrefixAndIndex(long idPrefix, int index) {
return idPrefix * 10000 + index;
}
@@ -64,7 +63,6 @@ public class TaskLocation implements
IdentifiedDataSerializable, Serializable {
return taskID;
}
- @SuppressWarnings("checkstyle:MagicNumber")
public long getTaskVertexId() {
return taskID / 10000;
}
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
index 686d2a04fe..73474ad776 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
@@ -167,7 +167,6 @@ public class JobHistoryService {
return objectNode.toString();
}
- @SuppressWarnings("checkstyle:MagicNumber")
public void storeFinishedJobState(JobMaster jobMaster) {
JobState jobState = toJobStateMapper(jobMaster, false);
jobState.setFinishTime(System.currentTimeMillis());
@@ -175,7 +174,6 @@ public class JobHistoryService {
finishedJobStateImap.put(jobState.jobId, jobState,
finishedJobExpireTime, TimeUnit.MINUTES);
}
- @SuppressWarnings("checkstyle:MagicNumber")
public void storeFinishedPipelineMetrics(long jobId, JobMetrics metrics) {
finishedJobMetricsImap.computeIfAbsent(jobId, key -> JobMetrics.of(new
HashMap<>()));
JobMetrics newMetrics =
finishedJobMetricsImap.get(jobId).merge(metrics);
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
index 5137f23b7b..5b329dbff8 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
@@ -300,7 +300,6 @@ public class JobMaster {
}));
}
- @SuppressWarnings("checkstyle:MagicNumber")
public void run() {
try {
if (!restore) {
@@ -669,7 +668,6 @@ public class JobMaster {
return ownedSlotProfilesIMap.get(pipelineLocation);
}
- @SuppressWarnings("checkstyle:MagicNumber")
public void setOwnedSlotProfiles(
@NonNull PipelineLocation pipelineLocation,
@NonNull Map<TaskGroupLocation, SlotProfile>
pipelineOwnedSlotProfiles) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/persistence/FileMapStore.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/persistence/FileMapStore.java
index ed47402e85..d81f14978e 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/persistence/FileMapStore.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/persistence/FileMapStore.java
@@ -80,7 +80,6 @@ public class FileMapStore implements MapStore<Object,
Object>, MapLoaderLifecycl
return null;
}
- @SuppressWarnings("checkstyle:MagicNumber")
@SneakyThrows
@Override
public Map<Object, Object> loadAll(Collection<Object> keys) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/CheckpointDataSerializerHook.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/CheckpointDataSerializerHook.java
index fb6cb2b7d0..3f5ce72cb9 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/CheckpointDataSerializerHook.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/CheckpointDataSerializerHook.java
@@ -66,7 +66,7 @@ public final class CheckpointDataSerializerHook implements
DataSerializerHook {
}
private static class Factory implements DataSerializableFactory {
- @SuppressWarnings("checkstyle:returncount")
+
@Override
public IdentifiedDataSerializable create(int typeId) {
switch (typeId) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
index 188e4fe065..78cf18c06b 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
@@ -79,7 +79,6 @@ public final class ClientToServerOperationDataSerializerHook
implements DataSeri
}
private static class Factory implements DataSerializableFactory {
- @SuppressWarnings("checkstyle:returncount")
@Override
public IdentifiedDataSerializable create(int typeId) {
switch (typeId) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
index 9c529d2def..aaae535598 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
@@ -136,7 +136,6 @@ public abstract class SeaTunnelTask extends AbstractTask {
.whenComplete((s, e) -> closeCalled = true);
}
- @SuppressWarnings("checkstyle:MagicNumber")
protected void stateProcess() throws Exception {
switch (currState) {
case INIT:
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java
index a904146a1d..014e5b4cd1 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java
@@ -132,7 +132,6 @@ public class SinkAggregatedCommitterTask<CommandInfoT,
AggregatedCommitInfoT>
return progress.toState();
}
- @SuppressWarnings("checkstyle:MagicNumber")
protected void stateProcess() throws Exception {
switch (currState) {
case INIT:
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java
index 25fdbc9638..1c8b25f37a 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java
@@ -202,7 +202,6 @@ public class SourceSplitEnumeratorTask<SplitT extends
SourceSplit> extends Coord
getEnumerator().addSplitsBack(splits, subtaskId);
}
- @SuppressWarnings("checkstyle:MagicNumber")
public void receivedReader(TaskLocation readerId, Address memberAddr)
throws InterruptedException, ExecutionException {
log.info("received reader register, readerID: " + readerId);
@@ -254,7 +253,6 @@ public class SourceSplitEnumeratorTask<SplitT extends
SourceSplit> extends Coord
return taskIndexToTaskLocationMapping.get(taskIndex);
}
- @SuppressWarnings("checkstyle:MagicNumber")
private SourceSplitEnumerator<SplitT, Serializable> getEnumerator()
throws InterruptedException, ExecutionException {
// (restoreComplete == null) means that the Task has not yet executed
Init, so we need to
@@ -274,7 +272,6 @@ public class SourceSplitEnumeratorTask<SplitT extends
SourceSplit> extends Coord
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
private void stateProcess() throws Exception {
switch (currState) {
case INIT:
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/IntermediateQueueFlowLifeCycle.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/IntermediateQueueFlowLifeCycle.java
index 8257997f97..8765f49b98 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/IntermediateQueueFlowLifeCycle.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/IntermediateQueueFlowLifeCycle.java
@@ -46,7 +46,6 @@ public class IntermediateQueueFlowLifeCycle<T extends
AbstractIntermediateQueue<
queue.received(record);
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void collect(Collector<Record<?>> collector) throws Exception {
queue.collect(collector);
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateBlockingQueue.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateBlockingQueue.java
index 5b2de4c50c..f7cd7b0c23 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateBlockingQueue.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateBlockingQueue.java
@@ -42,7 +42,6 @@ public class IntermediateBlockingQueue extends
AbstractIntermediateQueue<Blockin
}
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void collect(Collector<Record<?>> collector) throws Exception {
while (true) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateDisruptor.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateDisruptor.java
index a452995881..e2f3ed69d7 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateDisruptor.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/IntermediateDisruptor.java
@@ -44,7 +44,6 @@ public class IntermediateDisruptor extends
AbstractIntermediateQueue<Disruptor<R
getIntermediateQueueFlowLifeCycle());
}
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void collect(Collector<Record<?>> collector) throws Exception {
if (!isExecuted) {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/disruptor/RecordEventProducer.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/disruptor/RecordEventProducer.java
index 094ae9acf8..021bb8d2f0 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/disruptor/RecordEventProducer.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/disruptor/RecordEventProducer.java
@@ -26,7 +26,6 @@ import com.lmax.disruptor.RingBuffer;
public class RecordEventProducer {
- @SuppressWarnings("checkstyle:MagicNumber")
public static void onData(
Record<?> record,
RingBuffer<RecordEvent> ringBuffer,
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/CoordinatorServiceTest.java
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/CoordinatorServiceTest.java
index 3cb224e69e..320ce05e3e 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/CoordinatorServiceTest.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/CoordinatorServiceTest.java
@@ -82,7 +82,6 @@ public class CoordinatorServiceTest {
instance2.shutdown();
}
- @SuppressWarnings("checkstyle:RegexpSingleline")
@Test
public void testClearCoordinatorService()
throws MalformedURLException, NoSuchMethodException,
InvocationTargetException,
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TestUtils.java
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TestUtils.java
index 0481256ce4..571a3c95db 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TestUtils.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TestUtils.java
@@ -52,7 +52,6 @@ public class TestUtils {
return System.getProperty("user.dir") + "/src/test/resources/" +
confFile;
}
- @SuppressWarnings("checkstyle:MagicNumber")
public static LogicalDag getTestLogicalDag(JobContext jobContext) throws
MalformedURLException {
IdGenerator idGenerator = new IdGenerator();
FakeSource fakeSource = new FakeSource();
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobMetricsTest.java
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobMetricsTest.java
index 5b0a75abf5..896037edcf 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobMetricsTest.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobMetricsTest.java
@@ -96,7 +96,6 @@ class JobMetricsTest extends AbstractSeaTunnelServerTest {
}
@Test
- @SuppressWarnings("checkstyle:RegexpSingleline")
public void testMetricsOnJobRestart() throws InterruptedException {
long jobId3 = System.currentTimeMillis() + 323475L;
diff --git
a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/common/WALDataUtils.java
b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/common/WALDataUtils.java
index e475fde53a..ffa38502d7 100644
---
a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/common/WALDataUtils.java
+++
b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/common/WALDataUtils.java
@@ -20,7 +20,6 @@
package org.apache.seatunnel.engine.imap.storage.file.common;
-// CHECKSTYLE:OFF
public class WALDataUtils {
public static final int WAL_DATA_METADATA_LENGTH = 12;
diff --git
a/seatunnel-formats/seatunnel-format-text/src/test/java/org/apache/seatunnel/format/text/TextFormatSchemaTest.java
b/seatunnel-formats/seatunnel-format-text/src/test/java/org/apache/seatunnel/format/text/TextFormatSchemaTest.java
index 7d904e2c8f..f099103efc 100644
---
a/seatunnel-formats/seatunnel-format-text/src/test/java/org/apache/seatunnel/format/text/TextFormatSchemaTest.java
+++
b/seatunnel-formats/seatunnel-format-text/src/test/java/org/apache/seatunnel/format/text/TextFormatSchemaTest.java
@@ -66,7 +66,6 @@ public class TextFormatSchemaTest {
public SeaTunnelRowType seaTunnelRowType;
- @SuppressWarnings("checkstyle:Indentation")
@BeforeEach
public void initSeaTunnelRowType() {
seaTunnelRowType =
diff --git
a/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
b/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
index 8b4ed6332b..c638d7f609 100644
---
a/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
+++
b/seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java
@@ -228,7 +228,6 @@ public abstract class AbstractPluginDiscovery<T> implements
PluginDiscovery<T> {
*
* @return the all plugin identifier of the engine
*/
- @SuppressWarnings("checkstyle:WhitespaceAfter")
public Map<PluginType, LinkedHashMap<PluginIdentifier, OptionRule>>
getAllPlugin()
throws IOException {
List<Factory> factories;
diff --git
a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
index f0c6fc2ae7..14f83ccd39 100644
---
a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
+++
b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
@@ -80,7 +80,6 @@ public abstract class BaseSeaTunnelSourceFunction extends
RichSourceFunction<Row
protected abstract BaseSourceFunction<SeaTunnelRow> createInternalSource();
- @SuppressWarnings("checkstyle:MagicNumber")
@Override
public void run(SourceFunction.SourceContext<Row> sourceContext) throws
Exception {
internalSource.run(
diff --git
a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java
b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java
index c904f52b51..fc8b4f6b3c 100644
---
a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java
+++
b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java
@@ -43,7 +43,6 @@ import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
-@SuppressWarnings("checkstyle:MagicNumber")
public class TypeConverterUtils {
private static final Map<Class<?>, BridgedType> BRIDGED_TYPES = new
HashMap<>(32);
