This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push: new d1b85d51a0 [code style](fe) Include test sources (#9366) d1b85d51a0 is described below commit d1b85d51a0cfe6dab47a5319929ed12b713efb3c Author: leo65535 <leo65...@163.com> AuthorDate: Mon May 9 09:40:44 2022 +0800 [code style](fe) Include test sources (#9366) Include test sources, we also need to check them. --- .../common/jmockit/ConstructorReflection.java | 2 - .../java/org/apache/doris/common/io/HllTest.java | 4 +- .../org/apache/doris/alter/AlterJobV2Test.java | 3 - .../apache/doris/alter/SchemaChangeJobV2Test.java | 1 - .../doris/analysis/AlterSqlBlockRuleStmtTest.java | 2 - .../apache/doris/analysis/BinaryPredicateTest.java | 4 -- .../doris/analysis/CreateResourceStmtTest.java | 2 +- .../doris/analysis/CreateSqlBlockRuleStmtTest.java | 1 - .../apache/doris/analysis/CreateTableStmtTest.java | 2 +- .../apache/doris/analysis/CreateUserStmtTest.java | 2 +- .../doris/analysis/DropColumnClauseTest.java | 2 +- .../org/apache/doris/analysis/DropDbStmtTest.java | 2 +- .../apache/doris/analysis/DropIndexClauseTest.java | 3 +- .../doris/analysis/DropRollupClauseTest.java | 2 +- .../apache/doris/analysis/DropTableStmtTest.java | 2 +- .../apache/doris/analysis/DropUserStmtTest.java | 2 +- .../org/apache/doris/analysis/HelpStmtTest.java | 2 +- .../apache/doris/analysis/InsertArrayStmtTest.java | 2 +- .../doris/analysis/InstallPluginStmtTest.java | 2 - .../org/apache/doris/analysis/KillStmtTest.java | 2 +- .../org/apache/doris/analysis/LabelNameTest.java | 2 +- .../org/apache/doris/analysis/LoadStmtTest.java | 2 +- .../doris/analysis/ModifyColumnClauseTest.java | 2 +- .../doris/analysis/OutFileClauseFunctionTest.java | 2 - .../doris/analysis/ReorderColumnsClauseTest.java | 2 +- .../org/apache/doris/analysis/SeparatorTest.java | 2 +- .../org/apache/doris/analysis/SetNamesVarTest.java | 2 +- .../org/apache/doris/analysis/SetPassVarTest.java | 2 +- .../org/apache/doris/analysis/SetStmtTest.java | 2 +- .../org/apache/doris/analysis/SetTypeTest.java | 2 +- .../doris/analysis/SetUserPropertyStmtTest.java | 2 +- .../doris/analysis/SetUserPropertyVarTest.java | 2 +- .../java/org/apache/doris/analysis/SetVarTest.java | 3 +- .../org/apache/doris/analysis/SetVariableTest.java | 2 +- .../doris/analysis/ShowCreateTableStmtTest.java | 2 +- .../apache/doris/analysis/ShowDbIdStmtTest.java | 2 +- .../org/apache/doris/analysis/ShowDbStmtTest.java | 2 +- .../apache/doris/analysis/ShowEnginesStmtTest.java | 2 +- .../apache/doris/analysis/ShowIndexStmtTest.java | 2 +- .../apache/doris/analysis/ShowLoadStmtTest.java | 2 - .../doris/analysis/ShowPartitionIdStmtTest.java | 2 +- .../doris/analysis/ShowResourcesStmtTest.java | 2 +- .../apache/doris/analysis/ShowRollupStmtTest.java | 2 +- .../doris/analysis/ShowTableCreationStmtTest.java | 2 +- .../apache/doris/analysis/ShowTableIdStmtTest.java | 17 +++-- .../doris/analysis/ShowUserPropertyStmtTest.java | 2 +- .../doris/analysis/ShowVariablesStmtTest.java | 2 +- .../apache/doris/analysis/SysVariableDescTest.java | 2 +- .../org/apache/doris/analysis/UseStmtTest.java | 2 +- .../org/apache/doris/backup/S3StorageTest.java | 2 +- .../doris/blockrule/SqlBlockRuleMgrTest.java | 2 - .../java/org/apache/doris/catalog/CatalogTest.java | 6 -- .../org/apache/doris/catalog/DataPropertyTest.java | 2 +- .../org/apache/doris/catalog/DatabaseTest.java | 1 - .../apache/doris/catalog/DropPartitionTest.java | 2 +- .../java/org/apache/doris/catalog/FakeCatalog.java | 2 +- .../org/apache/doris/catalog/InfoSchemaDbTest.java | 2 +- .../doris/catalog/OdbcCatalogResourceTest.java | 2 +- .../apache/doris/catalog/ResourceGroupTest.java | 2 +- .../java/org/apache/doris/catalog/TableTest.java | 2 - .../org/apache/doris/catalog/UserPropertyTest.java | 1 - .../org/apache/doris/catalog/UserResourceTest.java | 2 +- .../org/apache/doris/common/GenericPoolTest.java | 2 +- .../apache/doris/common/PatternMatcherTest.java | 2 +- .../org/apache/doris/common/path/PathTrieTest.java | 6 -- .../apache/doris/common/proc/ProcServiceTest.java | 2 +- .../common/util/DynamicPartitionUtilTest.java | 1 - .../org/apache/doris/common/util/S3URITest.java | 2 +- .../java/org/apache/doris/common/util/URITest.java | 2 +- .../external/elasticsearch/QueryBuildersTest.java | 1 - .../org/apache/doris/http/HttpAuthManagerTest.java | 1 - .../org/apache/doris/load/DeleteHandlerTest.java | 1 - .../doris/load/loadv2/SparkEtlJobHandlerTest.java | 2 +- .../load/routineload/KafkaRoutineLoadJobTest.java | 4 +- .../load/routineload/RoutineLoadManagerTest.java | 4 +- .../load/routineload/RoutineLoadSchedulerTest.java | 1 - .../routineload/RoutineLoadTaskSchedulerTest.java | 2 +- .../apache/doris/load/sync/SyncJobManagerTest.java | 2 +- .../org/apache/doris/load/sync/SyncJobTest.java | 4 +- .../apache/doris/mysql/MysqlAuthPacketTest.java | 2 +- .../apache/doris/mysql/MysqlCapabilityTest.java | 2 +- .../org/apache/doris/mysql/MysqlColDefTest.java | 2 +- .../org/apache/doris/mysql/MysqlColTypeTest.java | 2 +- .../org/apache/doris/mysql/MysqlCommandTest.java | 2 +- .../org/apache/doris/mysql/MysqlEofPacketTest.java | 2 +- .../org/apache/doris/mysql/MysqlPasswordTest.java | 2 +- .../org/apache/doris/mysql/MysqlServerTest.java | 2 +- .../apache/doris/persist/CreateTableInfoTest.java | 2 - .../persist/RefreshExternalTableInfoTest.java | 1 - .../doris/planner/RuntimeFilterGeneratorTest.java | 2 - .../doris/planner/SingleNodePlannerTest.java | 3 - .../doris/planner/TableFunctionPlanTest.java | 2 - .../java/org/apache/doris/qe/CoordinatorTest.java | 73 +++++++++++----------- .../java/org/apache/doris/qe/HelpModuleTest.java | 2 - .../org/apache/doris/qe/QueryDetailQueueTest.java | 5 -- .../java/org/apache/doris/qe/QueryStateTest.java | 2 +- .../org/apache/doris/qe/SessionVariablesTest.java | 2 +- .../java/org/apache/doris/qe/SetExecutorTest.java | 2 +- .../apache/doris/qe/ShowResultSetMetaDataTest.java | 2 +- .../org/apache/doris/qe/ShowResultSetTest.java | 2 +- .../apache/doris/rewrite/InferFiltersRuleTest.java | 2 - .../doris/rewrite/RewriteDateLiteralRuleTest.java | 2 +- .../org/apache/doris/service/ExecuteEnvTest.java | 1 - .../org/apache/doris/system/HeartbeatMgrTest.java | 2 - .../org/apache/doris/task/LoadPendingTaskTest.java | 1 - .../apache/doris/utframe/MockedBackendFactory.java | 2 +- .../java/org/apache/doris/udf/UdfExecutorTest.java | 11 +++- fe/pom.xml | 1 + .../load/loadv2/dpp/DorisRangePartitionerTest.java | 9 +-- .../apache/doris/load/loadv2/dpp/DppUtilsTest.java | 7 +-- .../dpp/MinimumCoverageRollupTreeBuilderTest.java | 6 +- .../apache/doris/load/loadv2/dpp/SparkDppTest.java | 1 - .../doris/load/loadv2/etl/SparkEtlJobTest.java | 2 +- 113 files changed, 140 insertions(+), 208 deletions(-) diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/jmockit/ConstructorReflection.java b/fe/fe-common/src/main/java/org/apache/doris/common/jmockit/ConstructorReflection.java index a23009e0a1..e270078739 100644 --- a/fe/fe-common/src/main/java/org/apache/doris/common/jmockit/ConstructorReflection.java +++ b/fe/fe-common/src/main/java/org/apache/doris/common/jmockit/ConstructorReflection.java @@ -5,8 +5,6 @@ package org.apache.doris.common.jmockit; -import org.apache.doris.common.jmockit.ParameterReflection; - import java.lang.reflect.AccessibleObject; import java.lang.reflect.Constructor; import java.lang.reflect.InvocationTargetException; diff --git a/fe/fe-common/src/test/java/org/apache/doris/common/io/HllTest.java b/fe/fe-common/src/test/java/org/apache/doris/common/io/HllTest.java index 4253d3fe27..eecf3ecb94 100644 --- a/fe/fe-common/src/test/java/org/apache/doris/common/io/HllTest.java +++ b/fe/fe-common/src/test/java/org/apache/doris/common/io/HllTest.java @@ -33,8 +33,8 @@ public class HllTest { public void testFindFirstNonZeroBitPosition() { Assert.assertTrue(Hll.getLongTailZeroNum(0) == 0); Assert.assertTrue(Hll.getLongTailZeroNum(1) == 0); - Assert.assertTrue(Hll.getLongTailZeroNum(1l << 30) == 30); - Assert.assertTrue(Hll.getLongTailZeroNum(1l << 62) == 62); + Assert.assertTrue(Hll.getLongTailZeroNum(1L << 30) == 30); + Assert.assertTrue(Hll.getLongTailZeroNum(1L << 62) == 62); } @Test diff --git a/fe/fe-core/src/test/java/org/apache/doris/alter/AlterJobV2Test.java b/fe/fe-core/src/test/java/org/apache/doris/alter/AlterJobV2Test.java index 289e45c285..5e68656d66 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/alter/AlterJobV2Test.java +++ b/fe/fe-core/src/test/java/org/apache/doris/alter/AlterJobV2Test.java @@ -26,14 +26,11 @@ import org.apache.doris.catalog.Catalog; import org.apache.doris.catalog.Database; import org.apache.doris.catalog.OlapTable; import org.apache.doris.catalog.Table; -import org.apache.doris.common.Config; -import org.apache.doris.common.DdlException; import org.apache.doris.common.ExceptionChecker; import org.apache.doris.common.FeConstants; import org.apache.doris.qe.ConnectContext; import org.apache.doris.qe.ShowExecutor; import org.apache.doris.qe.ShowResultSet; -import org.apache.doris.thrift.TStorageFormat; import org.apache.doris.utframe.UtFrameUtils; import org.junit.AfterClass; diff --git a/fe/fe-core/src/test/java/org/apache/doris/alter/SchemaChangeJobV2Test.java b/fe/fe-core/src/test/java/org/apache/doris/alter/SchemaChangeJobV2Test.java index 6d78eb84a0..df76df694e 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/alter/SchemaChangeJobV2Test.java +++ b/fe/fe-core/src/test/java/org/apache/doris/alter/SchemaChangeJobV2Test.java @@ -66,7 +66,6 @@ import org.apache.doris.transaction.GlobalTransactionMgr; import com.google.common.collect.Maps; -import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec; import org.junit.Assert; import org.junit.Before; import org.junit.Rule; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/AlterSqlBlockRuleStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/AlterSqlBlockRuleStmtTest.java index 1797655823..19de580c76 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/AlterSqlBlockRuleStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/AlterSqlBlockRuleStmtTest.java @@ -17,10 +17,8 @@ package org.apache.doris.analysis; -import org.apache.doris.analysis.CreateSqlBlockRuleStmt; import org.apache.doris.blockrule.SqlBlockRule; import org.apache.doris.common.AnalysisException; -import org.apache.doris.common.ErrorReport; import org.apache.doris.common.ExceptionChecker; import org.apache.doris.common.UserException; import org.apache.doris.mysql.privilege.MockedAuth; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/BinaryPredicateTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/BinaryPredicateTest.java index 5b6aff9323..436724d62b 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/BinaryPredicateTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/BinaryPredicateTest.java @@ -25,10 +25,6 @@ import org.apache.doris.common.jmockit.Deencapsulation; import com.google.common.collect.BoundType; import com.google.common.collect.Lists; import com.google.common.collect.Range; -import com.google.common.collect.RangeSet; -import com.google.common.collect.TreeRangeSet; - -import java.util.List; import mockit.Expectations; import mockit.Injectable; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateResourceStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateResourceStmtTest.java index b7d66ff531..90648f9c32 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateResourceStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateResourceStmtTest.java @@ -103,4 +103,4 @@ public class CreateResourceStmtTest { CreateResourceStmt stmt = new CreateResourceStmt(true, resourceName1, properties); stmt.analyze(analyzer); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateSqlBlockRuleStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateSqlBlockRuleStmtTest.java index fd54a50c10..84750da093 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateSqlBlockRuleStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateSqlBlockRuleStmtTest.java @@ -19,7 +19,6 @@ package org.apache.doris.analysis; import org.apache.doris.blockrule.SqlBlockRule; import org.apache.doris.common.AnalysisException; -import org.apache.doris.common.DdlException; import org.apache.doris.common.ExceptionChecker; import org.apache.doris.common.UserException; import org.apache.doris.mysql.privilege.MockedAuth; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableStmtTest.java index 624b829e62..c5f226b063 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableStmtTest.java @@ -276,4 +276,4 @@ public class CreateTableStmtTest { "\"iceberg.hive.metastore.uris\" = \"thrift://127.0.0.1:9087\",\n" + "\"iceberg.table\" = \"test\")", stmt.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateUserStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateUserStmtTest.java index c40bf27b9a..40a372291f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateUserStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateUserStmtTest.java @@ -105,4 +105,4 @@ public class CreateUserStmtTest { stmt.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropColumnClauseTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropColumnClauseTest.java index 19bee3dc13..cd29e6995c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropColumnClauseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropColumnClauseTest.java @@ -51,4 +51,4 @@ public class DropColumnClauseTest { clause.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropDbStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropDbStmtTest.java index e281735fe5..9580ca7e70 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropDbStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropDbStmtTest.java @@ -68,4 +68,4 @@ public class DropDbStmtTest { stmt.analyze(AccessTestUtil.fetchBlockAnalyzer()); Assert.fail("no exception"); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropIndexClauseTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropIndexClauseTest.java index b2f8b95611..7f7c52109d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropIndexClauseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropIndexClauseTest.java @@ -17,7 +17,6 @@ package org.apache.doris.analysis; -import org.apache.doris.catalog.Catalog; import org.apache.doris.common.AnalysisException; import org.apache.doris.common.UserException; @@ -46,4 +45,4 @@ public class DropIndexClauseTest { DropIndexClause clause = new DropIndexClause("", false, new TableName("db", "table"), false); clause.analyze(analyzer); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropRollupClauseTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropRollupClauseTest.java index 2783bf5ba1..52893728f2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropRollupClauseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropRollupClauseTest.java @@ -45,4 +45,4 @@ public class DropRollupClauseTest { clause.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropTableStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropTableStmtTest.java index f33fcaab35..c3392d19fd 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropTableStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropTableStmtTest.java @@ -96,4 +96,4 @@ public class DropTableStmtTest { Assert.fail("No Exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropUserStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropUserStmtTest.java index a14467efed..9f872038f6 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/DropUserStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/DropUserStmtTest.java @@ -58,4 +58,4 @@ public class DropUserStmtTest { stmt.analyze(analyzer); Assert.fail("No Exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/HelpStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/HelpStmtTest.java index 21d9e8fbc2..e6da79e4f1 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/HelpStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/HelpStmtTest.java @@ -41,4 +41,4 @@ public class HelpStmtTest { stmt.analyze(null); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/InsertArrayStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/InsertArrayStmtTest.java index ad0d8325fa..b381a77f26 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/InsertArrayStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/InsertArrayStmtTest.java @@ -111,4 +111,4 @@ public class InsertArrayStmtTest { parseAndAnalyze("insert into test.table1 values (1, [[1, 2], [3, 4]]);"); }); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/InstallPluginStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/InstallPluginStmtTest.java index a28963d74e..264c0b76ac 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/InstallPluginStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/InstallPluginStmtTest.java @@ -20,8 +20,6 @@ package org.apache.doris.analysis; import com.google.common.collect.Maps; import mockit.Expectations; import mockit.Mocked; -import org.apache.doris.catalog.Catalog; -import org.apache.doris.catalog.FakeCatalog; import org.apache.doris.common.UserException; import org.apache.doris.mysql.privilege.PaloAuth; import org.apache.doris.mysql.privilege.PrivPredicate; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/KillStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/KillStmtTest.java index 0da23c6cb5..0915732f86 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/KillStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/KillStmtTest.java @@ -35,4 +35,4 @@ public class KillStmtTest { Assert.assertEquals(2, stmt.getConnectionId()); Assert.assertEquals("KILL 2", stmt.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/LabelNameTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/LabelNameTest.java index e2e367a500..7c595a8b39 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/LabelNameTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/LabelNameTest.java @@ -91,4 +91,4 @@ public class LabelNameTest { Assert.fail("No exception throws"); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java index aee6eed42e..4d078f5f5c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java @@ -186,4 +186,4 @@ public class LoadStmtTest { new SqlScanner( new StringReader(columnsSQL))))).getColumns(); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ModifyColumnClauseTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ModifyColumnClauseTest.java index 074678b6ea..7f344089aa 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ModifyColumnClauseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ModifyColumnClauseTest.java @@ -81,4 +81,4 @@ public class ModifyColumnClauseTest { clause.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/OutFileClauseFunctionTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/OutFileClauseFunctionTest.java index d2bc45a9a0..7f7410ee22 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/OutFileClauseFunctionTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/OutFileClauseFunctionTest.java @@ -22,9 +22,7 @@ import org.apache.doris.common.Config; import org.apache.doris.common.FeConstants; import org.apache.doris.common.jmockit.Deencapsulation; import org.apache.doris.qe.ConnectContext; -import org.apache.doris.qe.StmtExecutor; import org.apache.doris.thrift.TFileFormatType; -import org.apache.doris.utframe.DorisAssert; import org.apache.doris.utframe.UtFrameUtils; import java.io.File; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ReorderColumnsClauseTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ReorderColumnsClauseTest.java index 8a40c863bb..e8cd35c242 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ReorderColumnsClauseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ReorderColumnsClauseTest.java @@ -64,4 +64,4 @@ public class ReorderColumnsClauseTest { clause.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SeparatorTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SeparatorTest.java index 5fd8e7bc54..4618e395be 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SeparatorTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SeparatorTest.java @@ -77,4 +77,4 @@ public class SeparatorTest { Separator separator = new Separator("\\x011"); separator.analyze(); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetNamesVarTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetNamesVarTest.java index 8d9558379e..81bf4509c8 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetNamesVarTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetNamesVarTest.java @@ -56,4 +56,4 @@ public class SetNamesVarTest { var.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetPassVarTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetPassVarTest.java index d6d591cb37..5018f10c56 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetPassVarTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetPassVarTest.java @@ -80,4 +80,4 @@ public class SetPassVarTest { Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetStmtTest.java index 3280ce0062..6d8f826d8b 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetStmtTest.java @@ -75,4 +75,4 @@ public class SetStmtTest { stmt.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetTypeTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetTypeTest.java index d2e5279ab1..8e165a544d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetTypeTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetTypeTest.java @@ -28,4 +28,4 @@ public class SetTypeTest { Assert.assertEquals("GLOBAL", SetType.GLOBAL.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyStmtTest.java index 7dbcee7819..7c0bcab017 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyStmtTest.java @@ -65,4 +65,4 @@ public class SetUserPropertyStmtTest { stmt.analyze(analyzer); Assert.fail("No exception throws"); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyVarTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyVarTest.java index 4c5be14f04..a4d432db8a 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyVarTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetUserPropertyVarTest.java @@ -51,4 +51,4 @@ public class SetUserPropertyVarTest { var.analyze(analyzer, true); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVarTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVarTest.java index 1308ad7424..fa39087d47 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVarTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVarTest.java @@ -23,7 +23,6 @@ import org.apache.doris.mysql.privilege.MockedAuth; import org.apache.doris.mysql.privilege.PaloAuth; import org.apache.doris.qe.ConnectContext; -import org.apache.doris.qe.SqlModeHelper; import org.junit.Assert; import org.junit.Before; import org.junit.Test; @@ -69,4 +68,4 @@ public class SetVarTest { var.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVariableTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVariableTest.java index 700a36ccaf..eac8928701 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVariableTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SetVariableTest.java @@ -69,4 +69,4 @@ public class SetVariableTest { stmtExecutor.execute(); Assert.assertEquals(21474836480L, connectContext.getSessionVariable().getMaxExecMemByte()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowCreateTableStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowCreateTableStmtTest.java index 58f5c1c1ec..78dee03f19 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowCreateTableStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowCreateTableStmtTest.java @@ -61,4 +61,4 @@ public class ShowCreateTableStmtTest { stmt.analyze(analyzer); Assert.fail("No Exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbIdStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbIdStmtTest.java index d2b38eb193..887e8504eb 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbIdStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbIdStmtTest.java @@ -50,4 +50,4 @@ public class ShowDbIdStmtTest { Assert.assertEquals(1, stmt.getMetaData().getColumnCount()); Assert.assertEquals("DbName", stmt.getMetaData().getColumn(0).getName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbStmtTest.java index 024799b073..551a5b738c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbStmtTest.java @@ -41,4 +41,4 @@ public class ShowDbStmtTest { Assert.assertEquals(1, stmt.getMetaData().getColumnCount()); Assert.assertEquals("Database", stmt.getMetaData().getColumn(0).getName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowEnginesStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowEnginesStmtTest.java index 1c29c0a8ee..8daf1e39c6 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowEnginesStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowEnginesStmtTest.java @@ -39,4 +39,4 @@ public class ShowEnginesStmtTest { Assert.assertEquals("Savepoints", metaData.getColumn(5).getName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowIndexStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowIndexStmtTest.java index 35a35f635b..2d2c12f72f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowIndexStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowIndexStmtTest.java @@ -66,4 +66,4 @@ public class ShowIndexStmtTest { ShowIndexStmt stmt = new ShowIndexStmt("testDb", new TableName("", "")); stmt.analyze(analyzer); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowLoadStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowLoadStmtTest.java index 2b7e3cd399..a22b48d310 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowLoadStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowLoadStmtTest.java @@ -18,8 +18,6 @@ package org.apache.doris.analysis; import org.apache.doris.analysis.BinaryPredicate.Operator; -import org.apache.doris.analysis.CompoundPredicate; -import org.apache.doris.analysis.LikePredicate; import org.apache.doris.catalog.Catalog; import org.apache.doris.catalog.FakeCatalog; import org.apache.doris.common.AnalysisException; diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowPartitionIdStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowPartitionIdStmtTest.java index 346124b4ac..5374b0910d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowPartitionIdStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowPartitionIdStmtTest.java @@ -55,4 +55,4 @@ public class ShowPartitionIdStmtTest { Assert.assertEquals("DbId", stmt.getMetaData().getColumn(3).getName()); Assert.assertEquals("TableId", stmt.getMetaData().getColumn(4).getName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowResourcesStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowResourcesStmtTest.java index b706d9c948..4f7e924c10 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowResourcesStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowResourcesStmtTest.java @@ -75,4 +75,4 @@ public class ShowResourcesStmtTest { stmt.analyze(analyzer); Assert.assertEquals("SHOW RESOURCES WHERE `name` LIKE \'abc\' LIMIT 10", stmt.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowRollupStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowRollupStmtTest.java index 76633e69bd..9647ac54a5 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowRollupStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowRollupStmtTest.java @@ -62,4 +62,4 @@ public class ShowRollupStmtTest { stmt.analyze(analyzer); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableCreationStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableCreationStmtTest.java index 033c27af52..fa45a10888 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableCreationStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableCreationStmtTest.java @@ -58,4 +58,4 @@ public class ShowTableCreationStmtTest { stmt.analyze(analyzer); Assert.assertEquals("testCluster:testDb", stmt.getDbName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableIdStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableIdStmtTest.java index 995208af65..ba8651e9b2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableIdStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowTableIdStmtTest.java @@ -17,11 +17,16 @@ package org.apache.doris.analysis; +import org.apache.doris.common.AnalysisException; +import org.apache.doris.common.UserException; +import org.apache.doris.mysql.privilege.MockedAuth; +import org.apache.doris.mysql.privilege.PaloAuth; +import org.apache.doris.qe.ConnectContext; + +import org.junit.Assert; +import org.junit.Before; +import org.junit.Test; import mockit.Mocked; -import org.apache.doris.common.*; -import org.apache.doris.mysql.privilege.*; -import org.apache.doris.qe.*; -import org.junit.*; public class ShowTableIdStmtTest { private Analyzer analyzer; @@ -39,7 +44,7 @@ public class ShowTableIdStmtTest { } @Test - public void testNormal() throws UserException, AnalysisException { + public void testNormal() throws UserException, AnalysisException { ShowTableIdStmt stmt = new ShowTableIdStmt(123456); stmt.analyze(analyzer); Assert.assertEquals("SHOW TABLE 123456", stmt.toString()); @@ -48,4 +53,4 @@ public class ShowTableIdStmtTest { Assert.assertEquals("TableName", stmt.getMetaData().getColumn(1).getName()); Assert.assertEquals("DbId", stmt.getMetaData().getColumn(2).getName()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowUserPropertyStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowUserPropertyStmtTest.java index 02c7b1ddad..ec0fb082c7 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowUserPropertyStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowUserPropertyStmtTest.java @@ -50,4 +50,4 @@ public class ShowUserPropertyStmtTest { stmt.analyze(analyzer); Assert.assertEquals("SHOW PROPERTY FOR 'testCluster:testUser' LIKE '%load_cluster%'", stmt.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowVariablesStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowVariablesStmtTest.java index 699efacb9c..da8d3004c3 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowVariablesStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/ShowVariablesStmtTest.java @@ -43,4 +43,4 @@ public class ShowVariablesStmtTest { assertEquals("abc", stmt.getPattern()); assertEquals(SetType.GLOBAL, stmt.getType()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/SysVariableDescTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/SysVariableDescTest.java index d5ab60d9b9..fcc8b8ddf2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/SysVariableDescTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/SysVariableDescTest.java @@ -50,4 +50,4 @@ public class SysVariableDescTest { Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/UseStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/UseStmtTest.java index 1767866f87..06693af6b2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/analysis/UseStmtTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/UseStmtTest.java @@ -60,4 +60,4 @@ public class UseStmtTest { Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/backup/S3StorageTest.java b/fe/fe-core/src/test/java/org/apache/doris/backup/S3StorageTest.java index be740352e5..cdbe6d4ca2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/backup/S3StorageTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/backup/S3StorageTest.java @@ -164,4 +164,4 @@ public class S3StorageTest { status = storage.checkPathExist(testFile + ".NOT_EXIST"); Assert.assertEquals(Status.ErrCode.NOT_FOUND, status.getErrCode()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/blockrule/SqlBlockRuleMgrTest.java b/fe/fe-core/src/test/java/org/apache/doris/blockrule/SqlBlockRuleMgrTest.java index bf93eae895..021b97f0f5 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/blockrule/SqlBlockRuleMgrTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/blockrule/SqlBlockRuleMgrTest.java @@ -49,8 +49,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; -import java.util.HashMap; -import java.util.Map; public class SqlBlockRuleMgrTest { diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/CatalogTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/CatalogTest.java index 116ae1fc57..c9956d073b 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/CatalogTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/CatalogTest.java @@ -17,9 +17,6 @@ package org.apache.doris.catalog; -import org.apache.doris.alter.AlterJobV2.JobType; -import org.apache.doris.catalog.MaterializedIndex.IndexState; -import org.apache.doris.cluster.Cluster; import org.apache.doris.common.FeConstants; import org.apache.doris.common.MetaHeader; import org.apache.doris.common.io.CountingDataOutputStream; @@ -39,9 +36,6 @@ import java.io.FileOutputStream; import java.io.FileWriter; import java.io.IOException; import java.lang.reflect.Field; -import java.util.LinkedList; -import java.util.List; -import java.util.Map; import java.util.Random; import mockit.Expectations; diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/DataPropertyTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/DataPropertyTest.java index 701dfdcc95..b71f3a8676 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/DataPropertyTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/DataPropertyTest.java @@ -40,4 +40,4 @@ public class DataPropertyTest { dataProperty = new DataProperty(TStorageMedium.HDD); Assert.assertEquals(DataProperty.MAX_COOLDOWN_TIME_MS, dataProperty.getCooldownTimeMs()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/DatabaseTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/DatabaseTest.java index 05a8fb61dd..2d594aaccd 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/DatabaseTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/DatabaseTest.java @@ -17,7 +17,6 @@ package org.apache.doris.catalog; -import org.apache.doris.alter.AlterCancelException; import org.apache.doris.catalog.MaterializedIndex.IndexState; import org.apache.doris.common.DdlException; import org.apache.doris.common.ExceptionChecker; diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/DropPartitionTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/DropPartitionTest.java index 4b7dc55b3a..54b286d77f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/DropPartitionTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/DropPartitionTest.java @@ -129,4 +129,4 @@ public class DropPartitionTest { Assert.assertEquals(1, replicaList.size()); Assert.assertNull(partition); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/FakeCatalog.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/FakeCatalog.java index a70228a8c4..e5119f38c7 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/FakeCatalog.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/FakeCatalog.java @@ -60,4 +60,4 @@ public class FakeCatalog extends MockUp<Catalog> { return systemInfo; } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/InfoSchemaDbTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/InfoSchemaDbTest.java index 422a7acf66..797d8822f9 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/InfoSchemaDbTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/InfoSchemaDbTest.java @@ -34,4 +34,4 @@ public class InfoSchemaDbTest { db.write(null); Assert.assertNull(db.getTableNullable("authors")); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/OdbcCatalogResourceTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/OdbcCatalogResourceTest.java index dbc5f666cf..1ca5ff55f9 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/OdbcCatalogResourceTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/OdbcCatalogResourceTest.java @@ -155,4 +155,4 @@ public class OdbcCatalogResourceTest { dis.close(); file.delete(); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/ResourceGroupTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/ResourceGroupTest.java index ef3f7ba575..f5569d5eda 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/ResourceGroupTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/ResourceGroupTest.java @@ -54,4 +54,4 @@ public class ResourceGroupTest { Assert.assertEquals(150, newResource.getByDesc("cpu_share")); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/TableTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/TableTest.java index 6b0aa032f0..95c60b55a1 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/TableTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/TableTest.java @@ -26,7 +26,6 @@ import org.apache.doris.common.jmockit.Deencapsulation; import org.apache.doris.thrift.TStorageType; import com.google.common.collect.Lists; -import com.google.common.collect.Maps; import org.junit.Assert; import org.junit.Before; @@ -39,7 +38,6 @@ import java.io.FileInputStream; import java.io.FileOutputStream; import java.util.ArrayList; import java.util.List; -import java.util.Map; import java.util.concurrent.TimeUnit; public class TableTest { diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/UserPropertyTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/UserPropertyTest.java index f82c378929..5a7b100ddf 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/UserPropertyTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/UserPropertyTest.java @@ -29,7 +29,6 @@ import org.apache.doris.mysql.privilege.UserProperty; import com.google.common.collect.Lists; -import org.apache.doris.thrift.TStorageMedium; import org.junit.Assert; import org.junit.Before; import org.junit.Test; diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/UserResourceTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/UserResourceTest.java index 504d905015..1fb23783e5 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/UserResourceTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/UserResourceTest.java @@ -76,4 +76,4 @@ public class UserResourceTest { Assert.assertTrue(UserResource.isValidGroup("high")); Assert.assertFalse(UserResource.isValidGroup("high223")); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/GenericPoolTest.java b/fe/fe-core/src/test/java/org/apache/doris/common/GenericPoolTest.java index feab0c256e..55eb21d02c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/GenericPoolTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/GenericPoolTest.java @@ -198,7 +198,7 @@ public class GenericPoolTest { @Override public long getTrashUsedCapacity() throws TException { // TODO Auto-generated method stub - return 0l; + return 0L; } @Override diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/PatternMatcherTest.java b/fe/fe-core/src/test/java/org/apache/doris/common/PatternMatcherTest.java index 0f280d8562..adeda52c7d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/PatternMatcherTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/PatternMatcherTest.java @@ -126,4 +126,4 @@ public class PatternMatcherTest { System.out.println(e.getMessage()); } } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/path/PathTrieTest.java b/fe/fe-core/src/test/java/org/apache/doris/common/path/PathTrieTest.java index afeef0db1f..196959860f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/path/PathTrieTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/path/PathTrieTest.java @@ -19,17 +19,11 @@ package org.apache.doris.common.path; import static com.google.common.collect.Maps.newHashMap; -import org.apache.doris.service.ExecuteEnv; - -import com.google.common.collect.Maps; - import org.junit.Assert; import org.junit.Test; import java.util.Map; -import mockit.Injectable; - public class PathTrieTest { @Test public void testPath() { diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/proc/ProcServiceTest.java b/fe/fe-core/src/test/java/org/apache/doris/common/proc/ProcServiceTest.java index b0b94d021a..2feb909cd7 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/proc/ProcServiceTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/proc/ProcServiceTest.java @@ -173,4 +173,4 @@ public class ProcServiceTest { Assert.assertEquals(5, errCount); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/util/DynamicPartitionUtilTest.java b/fe/fe-core/src/test/java/org/apache/doris/common/util/DynamicPartitionUtilTest.java index 8ad45dd4b1..8fd2b34407 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/util/DynamicPartitionUtilTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/util/DynamicPartitionUtilTest.java @@ -21,7 +21,6 @@ import org.apache.doris.catalog.Column; import org.apache.doris.catalog.DynamicPartitionProperty; import org.apache.doris.catalog.RangePartitionInfo; import org.apache.doris.catalog.Type; -import org.apache.doris.common.DdlException; import org.apache.doris.common.jmockit.Deencapsulation; import com.google.common.collect.Maps; diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/util/S3URITest.java b/fe/fe-core/src/test/java/org/apache/doris/common/util/S3URITest.java index 52ab8363ab..383926d884 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/util/S3URITest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/util/S3URITest.java @@ -77,4 +77,4 @@ public class S3URITest { Assert.assertEquals("path/to/file", uri1.getKey()); Assert.assertEquals(p1, uri1.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/common/util/URITest.java b/fe/fe-core/src/test/java/org/apache/doris/common/util/URITest.java index bf4c990b23..073654083c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/common/util/URITest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/common/util/URITest.java @@ -94,4 +94,4 @@ public class URITest { URI myURI10 = URI.create("hdfs"); Assert.assertEquals(myURI10.getPath(), "hdfs"); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/external/elasticsearch/QueryBuildersTest.java b/fe/fe-core/src/test/java/org/apache/doris/external/elasticsearch/QueryBuildersTest.java index ebd0243432..46f50b8171 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/external/elasticsearch/QueryBuildersTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/external/elasticsearch/QueryBuildersTest.java @@ -26,7 +26,6 @@ import java.math.BigInteger; import java.util.Arrays; import java.util.Collections; import java.util.concurrent.atomic.AtomicBoolean; -import org.apache.doris.external.elasticsearch.QueryBuilders; import org.junit.Test; diff --git a/fe/fe-core/src/test/java/org/apache/doris/http/HttpAuthManagerTest.java b/fe/fe-core/src/test/java/org/apache/doris/http/HttpAuthManagerTest.java index 2cd23dc34d..59c1199b00 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/http/HttpAuthManagerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/http/HttpAuthManagerTest.java @@ -20,7 +20,6 @@ package org.apache.doris.http; import java.util.ArrayList; import java.util.List; import org.apache.doris.analysis.UserIdentity; -import org.apache.doris.httpv2.HttpAuthManager.SessionValue; import org.apache.doris.httpv2.HttpAuthManager; import org.junit.Assert; diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/DeleteHandlerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/DeleteHandlerTest.java index 035c3c5ba2..ba95caa7ad 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/DeleteHandlerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/DeleteHandlerTest.java @@ -32,7 +32,6 @@ import org.apache.doris.catalog.Replica; import org.apache.doris.catalog.Table; import org.apache.doris.catalog.TabletInvertedIndex; import org.apache.doris.catalog.TabletMeta; -import org.apache.doris.common.AnalysisException; import org.apache.doris.common.DdlException; import org.apache.doris.common.FeConstants; import org.apache.doris.common.MarkedCountDownLatch; diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/loadv2/SparkEtlJobHandlerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/loadv2/SparkEtlJobHandlerTest.java index a462630286..6965bdee3f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/loadv2/SparkEtlJobHandlerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/loadv2/SparkEtlJobHandlerTest.java @@ -430,4 +430,4 @@ public class SparkEtlJobHandlerTest { Assert.fail(e.getMessage()); } } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/KafkaRoutineLoadJobTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/KafkaRoutineLoadJobTest.java index 9a820ba1a1..03510dd8dd 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/KafkaRoutineLoadJobTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/KafkaRoutineLoadJobTest.java @@ -252,7 +252,7 @@ public class KafkaRoutineLoadJobTest { List<Pair<Integer, Long>> partitionIdToOffset = Lists.newArrayList(); List<PartitionInfo> kafkaPartitionInfoList = Lists.newArrayList(); for (String s : kafkaPartitionString.split(",")) { - partitionIdToOffset.add(new Pair<>(Integer.valueOf(s), 0l)); + partitionIdToOffset.add(new Pair<>(Integer.valueOf(s), 0L)); PartitionInfo partitionInfo = new PartitionInfo(topicName, Integer.valueOf(s), null, null, null); kafkaPartitionInfoList.add(partitionInfo); } @@ -262,7 +262,7 @@ public class KafkaRoutineLoadJobTest { Deencapsulation.setField(dsProperties, "kafkaTopic", topicName); Deencapsulation.setField(createRoutineLoadStmt, "dataSourceProperties", dsProperties); - long dbId = 1l; + long dbId = 1L; long tableId = 2L; new Expectations() { diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadManagerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadManagerTest.java index f9d538fb1b..bf26a8b4ca 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadManagerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadManagerTest.java @@ -370,7 +370,7 @@ public class RoutineLoadManagerTest { RoutineLoadManager routineLoadManager = new RoutineLoadManager(); Config.max_routine_load_task_num_per_be = 0; Map<Long, RoutineLoadJob> routineLoadJobMap = Maps.newHashMap(); - routineLoadJobMap.put(1l, routineLoadJob); + routineLoadJobMap.put(1L, routineLoadJob); Deencapsulation.setField(routineLoadManager, "idToRoutineLoadJob", routineLoadJobMap); @@ -817,7 +817,7 @@ public class RoutineLoadManagerTest { }; Map<Long, Integer> result = Deencapsulation.invoke(routineLoadManager, "getBeCurrentTasksNumMap"); - Assert.assertEquals(1, (int) result.get(1l)); + Assert.assertEquals(1, (int) result.get(1L)); } diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadSchedulerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadSchedulerTest.java index f072804295..a0f725099a 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadSchedulerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadSchedulerTest.java @@ -40,7 +40,6 @@ import org.junit.Test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; import mockit.Expectations; import mockit.Injectable; diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadTaskSchedulerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadTaskSchedulerTest.java index 8cb98d626c..2dfbe159f0 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadTaskSchedulerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadTaskSchedulerTest.java @@ -71,7 +71,7 @@ public class RoutineLoadTaskSchedulerTest { Deencapsulation.setField(kafkaProgress, "partitionIdToOffset", partitionIdToOffset); Queue<RoutineLoadTaskInfo> routineLoadTaskInfoQueue = Queues.newLinkedBlockingQueue(); - KafkaTaskInfo routineLoadTaskInfo1 = new KafkaTaskInfo(new UUID(1, 1), 1l, "default_cluster", 20000, + KafkaTaskInfo routineLoadTaskInfo1 = new KafkaTaskInfo(new UUID(1, 1), 1L, "default_cluster", 20000, partitionIdToOffset); routineLoadTaskInfoQueue.add(routineLoadTaskInfo1); diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobManagerTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobManagerTest.java index 457fe43bfd..e0f740642e 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobManagerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobManagerTest.java @@ -442,4 +442,4 @@ public class SyncJobManagerTest { } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobTest.java b/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobTest.java index 2467aac618..03f5033229 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobTest.java @@ -28,8 +28,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -import mockit.Mocked; - import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; @@ -95,4 +93,4 @@ public class SyncJobTest { file.delete(); } } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlAuthPacketTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlAuthPacketTest.java index 02c7d5b727..c020b66053 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlAuthPacketTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlAuthPacketTest.java @@ -61,4 +61,4 @@ public class MysqlAuthPacketTest { Assert.assertEquals("testDb", packet.getDb()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCapabilityTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCapabilityTest.java index 5aa4d04574..1d00a1e029 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCapabilityTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCapabilityTest.java @@ -39,4 +39,4 @@ public class MysqlCapabilityTest { + " | CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS | CLIENT_SESSION_TRACK | CLIENT_DEPRECATE_EOF", capability.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColDefTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColDefTest.java index 6e2129f243..21cedea817 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColDefTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColDefTest.java @@ -73,4 +73,4 @@ public class MysqlColDefTest { // Assert.assertEquals(0, MysqlProto.readInt2(buf)); // Assert.assertTrue(buf.remaining() == 0); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColTypeTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColTypeTest.java index d76ccad8ff..114907df95 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColTypeTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlColTypeTest.java @@ -61,4 +61,4 @@ public class MysqlColTypeTest { Assert.assertEquals("NULL", type.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCommandTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCommandTest.java index 97fad0c71e..e4640bcdd4 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCommandTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlCommandTest.java @@ -39,4 +39,4 @@ public class MysqlCommandTest { Assert.assertEquals("Quit", command.toString()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlEofPacketTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlEofPacketTest.java index 6f4faed2f3..68a42985bd 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlEofPacketTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlEofPacketTest.java @@ -53,4 +53,4 @@ public class MysqlEofPacketTest { Assert.assertEquals(0, buffer.remaining()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlPasswordTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlPasswordTest.java index 40303e7f21..4cc76e146f 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlPasswordTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlPasswordTest.java @@ -79,4 +79,4 @@ public class MysqlPasswordTest { Assert.fail("No exception throws"); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlServerTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlServerTest.java index 950230fc85..db7acf079d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlServerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlServerTest.java @@ -159,4 +159,4 @@ public class MysqlServerTest { Assert.assertEquals(2, submitFailNum); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/persist/CreateTableInfoTest.java b/fe/fe-core/src/test/java/org/apache/doris/persist/CreateTableInfoTest.java index ebda67a0ad..55b1b6c126 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/persist/CreateTableInfoTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/persist/CreateTableInfoTest.java @@ -24,7 +24,6 @@ import java.io.FileInputStream; import java.io.FileOutputStream; import java.util.ArrayList; import java.util.List; -import java.util.Map; import org.apache.doris.catalog.FakeCatalog; import org.apache.doris.catalog.ScalarType; @@ -48,7 +47,6 @@ import org.apache.doris.common.FeConstants; import org.apache.doris.thrift.TStorageType; import com.google.common.collect.Lists; -import com.google.common.collect.Maps; public class CreateTableInfoTest { private Catalog catalog; diff --git a/fe/fe-core/src/test/java/org/apache/doris/persist/RefreshExternalTableInfoTest.java b/fe/fe-core/src/test/java/org/apache/doris/persist/RefreshExternalTableInfoTest.java index 4bb56e0fda..8194b87e48 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/persist/RefreshExternalTableInfoTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/persist/RefreshExternalTableInfoTest.java @@ -24,7 +24,6 @@ import java.io.FileInputStream; import java.io.FileOutputStream; import java.util.ArrayList; import java.util.List; -import java.util.Map; import org.apache.doris.catalog.FakeCatalog; import org.apache.doris.catalog.ScalarType; diff --git a/fe/fe-core/src/test/java/org/apache/doris/planner/RuntimeFilterGeneratorTest.java b/fe/fe-core/src/test/java/org/apache/doris/planner/RuntimeFilterGeneratorTest.java index e03063c97b..fe8b6c0dad 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/planner/RuntimeFilterGeneratorTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/planner/RuntimeFilterGeneratorTest.java @@ -33,12 +33,10 @@ import org.apache.doris.catalog.Catalog; import org.apache.doris.catalog.Column; import org.apache.doris.catalog.PrimitiveType; import org.apache.doris.catalog.Table; -import org.apache.doris.common.AnalysisException; import org.apache.doris.common.UserException; import org.apache.doris.common.jmockit.Deencapsulation; import org.apache.doris.qe.ConnectContext; import org.apache.doris.thrift.TPartitionType; -import org.apache.doris.thrift.TRuntimeFilterMode; import com.google.common.collect.Lists; diff --git a/fe/fe-core/src/test/java/org/apache/doris/planner/SingleNodePlannerTest.java b/fe/fe-core/src/test/java/org/apache/doris/planner/SingleNodePlannerTest.java index 2639401160..c247ff9da4 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/planner/SingleNodePlannerTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/planner/SingleNodePlannerTest.java @@ -36,13 +36,10 @@ import org.apache.doris.analysis.TupleId; import org.apache.doris.catalog.Column; import org.apache.doris.catalog.Table; import org.apache.doris.common.Pair; -import org.apache.doris.common.UserException; import org.apache.doris.common.jmockit.Deencapsulation; import com.google.common.collect.Lists; -import org.apache.log4j.Level; -import org.apache.log4j.LogManager; import org.junit.Assert; import org.junit.Test; diff --git a/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java b/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java index 15d84f7f39..a9b59ab8f1 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java @@ -20,7 +20,6 @@ package org.apache.doris.planner; import org.apache.doris.analysis.CreateDbStmt; import org.apache.doris.analysis.CreateTableStmt; import org.apache.doris.analysis.CreateViewStmt; -import org.apache.doris.analysis.FunctionCallExpr; import org.apache.doris.catalog.Catalog; import org.apache.doris.qe.ConnectContext; import org.apache.doris.utframe.UtFrameUtils; @@ -29,7 +28,6 @@ import org.apache.commons.io.FileUtils; import org.junit.After; import org.junit.Assert; import org.junit.BeforeClass; -import org.junit.Ignore; import org.junit.Test; import java.io.File; diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/CoordinatorTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/CoordinatorTest.java index e355f6c247..036ba85743 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/CoordinatorTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/CoordinatorTest.java @@ -17,6 +17,11 @@ package org.apache.doris.qe; +import com.google.common.collect.ArrayListMultimap; +import com.google.common.collect.ImmutableMap; +import com.google.common.collect.Maps; +import mockit.Mocked; +import org.apache.commons.collections.map.HashedMap; import org.apache.doris.analysis.Analyzer; import org.apache.doris.analysis.BinaryPredicate; import org.apache.doris.analysis.BoolLiteral; @@ -46,15 +51,9 @@ import org.apache.doris.thrift.TScanRangeLocation; import org.apache.doris.thrift.TScanRangeLocations; import org.apache.doris.thrift.TScanRangeParams; import org.apache.doris.thrift.TUniqueId; - -import org.apache.commons.collections.map.HashedMap; import org.junit.Assert; import org.junit.Test; -import com.google.common.collect.ArrayListMultimap; -import com.google.common.collect.ImmutableMap; -import com.google.common.collect.Maps; - import java.util.ArrayList; import java.util.HashMap; import java.util.HashSet; @@ -62,8 +61,6 @@ import java.util.List; import java.util.Map; import java.util.Set; -import mockit.Mocked; - public class CoordinatorTest extends Coordinator { static Planner planner = new Planner(); static ConnectContext context = new ConnectContext(null); @@ -253,14 +250,14 @@ public class CoordinatorTest extends Coordinator { TNetworkAddress be2 = new TNetworkAddress("0.0.0.2", 3000); HashMap<Long, Backend> idToBackend = new HashMap<>(); - idToBackend.put(0l, backend0); - idToBackend.put(1l, backend1); - idToBackend.put(2l, backend2); + idToBackend.put(0L, backend0); + idToBackend.put(1L, backend1); + idToBackend.put(2L, backend2); Map<TNetworkAddress, Long> addressToBackendID = new HashMap<>(); - addressToBackendID.put(be0, 0l); - addressToBackendID.put(be1, 1l); - addressToBackendID.put(be2, 2l); + addressToBackendID.put(be0, 0L); + addressToBackendID.put(be1, 1L); + addressToBackendID.put(be2, 2L); Deencapsulation.invoke(bucketShuffleJoinController, "computeScanRangeAssignmentByBucket", olapScanNode, ImmutableMap.copyOf(idToBackend), addressToBackendID); @@ -377,14 +374,14 @@ public class CoordinatorTest extends Coordinator { TNetworkAddress be2 = new TNetworkAddress("0.0.0.2", 3000); HashMap<Long, Backend> idToBackend = new HashMap<>(); - idToBackend.put(0l, backend0); - idToBackend.put(1l, backend1); - idToBackend.put(2l, backend2); + idToBackend.put(0L, backend0); + idToBackend.put(1L, backend1); + idToBackend.put(2L, backend2); Map<TNetworkAddress, Long> addressToBackendID = new HashMap<>(); - addressToBackendID.put(be0, 0l); - addressToBackendID.put(be1, 1l); - addressToBackendID.put(be2, 2l); + addressToBackendID.put(be0, 0L); + addressToBackendID.put(be1, 1L); + addressToBackendID.put(be2, 2L); Deencapsulation.invoke(bucketShuffleJoinController, "computeScanRangeAssignmentByBucket", olapScanNode, ImmutableMap.copyOf(idToBackend), addressToBackendID); @@ -565,10 +562,11 @@ public class CoordinatorTest extends Coordinator { backend2.setBePort(9050); ImmutableMap<Long, Backend> idToBackend = - new ImmutableMap.Builder<Long, Backend>(). - put(0l, backend0). - put(1l, backend1). - put(2l, backend2).build(); + new ImmutableMap.Builder<Long, Backend>() + .put(0L, backend0) + .put(1L, backend1) + .put(2L, backend2) + .build(); Deencapsulation.setField(coordinator, "idToBackend", idToBackend); FragmentScanRangeAssignment assignment = new FragmentScanRangeAssignment(); List<TScanRangeLocations> locations = new ArrayList<>(); @@ -617,10 +615,11 @@ public class CoordinatorTest extends Coordinator { backend2.setBePort(9050); ImmutableMap<Long, Backend> idToBackend = - new ImmutableMap.Builder<Long, Backend>(). - put(0l, backend0). - put(1l, backend1). - put(2l, backend2).build(); + new ImmutableMap.Builder<Long, Backend>() + .put(0L, backend0) + .put(1L, backend1) + .put(2L, backend2) + .build(); Deencapsulation.setField(coordinator, "idToBackend", idToBackend); Map<PlanFragmentId, Map<Integer, TNetworkAddress>> fragmentIdToSeqToAddressMap = Maps.newHashMap(); fragmentIdToSeqToAddressMap.put(planFragmentId, new HashedMap()); @@ -680,10 +679,11 @@ public class CoordinatorTest extends Coordinator { addressToBackendID.put(tScanRangeLocation2.server, tScanRangeLocation2.backend_id); ImmutableMap<Long, Backend> idToBackend = - new ImmutableMap.Builder<Long, Backend>(). - put(0l, backend0). - put(1l, backend1). - put(2l, backend2).build(); + new ImmutableMap.Builder<Long, Backend>() + .put(0L, backend0) + .put(1L, backend1) + .put(2L, backend2) + .build(); Map<PlanFragmentId, Map<Long, Integer>> fragmentIdToBuckendIdBucketCountMap = Maps.newHashMap(); Map<Long, Integer> backendIdBucketCountMap = new HashMap<Long, Integer>(); fragmentIdToBuckendIdBucketCountMap.put(planFragmentId, backendIdBucketCountMap); @@ -814,10 +814,11 @@ public class CoordinatorTest extends Coordinator { backend2.setBePort(9050); ImmutableMap<Long, Backend> idToBackend = - new ImmutableMap.Builder<Long, Backend>(). - put(0l, backend0). - put(1l, backend1). - put(2l, backend2).build(); + new ImmutableMap.Builder<Long, Backend>() + .put(0L, backend0) + .put(1L, backend1) + .put(2L, backend2) + .build(); Deencapsulation.setField(coordinator, "idToBackend", idToBackend); Deencapsulation.invoke(coordinator, "computeScanRangeAssignment"); diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/HelpModuleTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/HelpModuleTest.java index 72ab60886f..238abe8a7c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/HelpModuleTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/HelpModuleTest.java @@ -17,8 +17,6 @@ package org.apache.doris.qe; -import mockit.Expectations; -import mockit.Injectable; import org.apache.doris.common.UserException; import com.google.common.collect.Lists; diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/QueryDetailQueueTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/QueryDetailQueueTest.java index cd7b707e81..a1c89a8d1d 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/QueryDetailQueueTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/QueryDetailQueueTest.java @@ -17,14 +17,9 @@ package org.apache.doris.qe; -import com.google.common.collect.Lists; import com.google.gson.Gson; -import org.apache.doris.qe.QueryDetail; -import org.apache.doris.qe.QueryDetailQueue; import org.junit.Assert; -import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; import java.util.List; diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/QueryStateTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/QueryStateTest.java index 99bcd47088..1f83c7c43c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/QueryStateTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/QueryStateTest.java @@ -40,4 +40,4 @@ public class QueryStateTest { } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/SessionVariablesTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/SessionVariablesTest.java index 98d7fc06d0..a5d91057c3 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/SessionVariablesTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/SessionVariablesTest.java @@ -67,4 +67,4 @@ public class SessionVariablesTest { sessionVariable.setForwardedSessionVariables(queryOptions); Assert.assertEquals(123, sessionVariable.getQueryTimeoutS()); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/SetExecutorTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/SetExecutorTest.java index 343c71014d..9c49f3f1d6 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/SetExecutorTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/SetExecutorTest.java @@ -93,4 +93,4 @@ public class SetExecutorTest { executor.execute(); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetMetaDataTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetMetaDataTest.java index d8965cfbf5..acd2bb541c 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetMetaDataTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetMetaDataTest.java @@ -46,4 +46,4 @@ public class ShowResultSetMetaDataTest { metaData.getColumn(1); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetTest.java b/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetTest.java index ac163810e3..e9493cf8cd 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/qe/ShowResultSetTest.java @@ -65,4 +65,4 @@ public class ShowResultSetTest { resultSet.getInt(0); Assert.fail("No exception throws."); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/rewrite/InferFiltersRuleTest.java b/fe/fe-core/src/test/java/org/apache/doris/rewrite/InferFiltersRuleTest.java index c3c14f9ca5..9e003a1d5a 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/rewrite/InferFiltersRuleTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/rewrite/InferFiltersRuleTest.java @@ -23,8 +23,6 @@ import org.apache.doris.common.FeConstants; import org.apache.doris.qe.SessionVariable; import org.apache.doris.utframe.DorisAssert; import org.apache.doris.utframe.UtFrameUtils; -import org.apache.logging.log4j.LogManager; -import org.apache.logging.log4j.Logger; import org.junit.AfterClass; import org.junit.Assert; import org.junit.BeforeClass; diff --git a/fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteDateLiteralRuleTest.java b/fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteDateLiteralRuleTest.java index 7828e62038..dc9f4d8270 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteDateLiteralRuleTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/rewrite/RewriteDateLiteralRuleTest.java @@ -147,4 +147,4 @@ public class RewriteDateLiteralRuleTest { plainString = dorisAssert.query(query).explainQuery(); Assert.assertTrue(plainString.contains("NULL")); } -} \ No newline at end of file +} diff --git a/fe/fe-core/src/test/java/org/apache/doris/service/ExecuteEnvTest.java b/fe/fe-core/src/test/java/org/apache/doris/service/ExecuteEnvTest.java index 724c27a530..fe1851b1c2 100755 --- a/fe/fe-core/src/test/java/org/apache/doris/service/ExecuteEnvTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/service/ExecuteEnvTest.java @@ -20,7 +20,6 @@ package org.apache.doris.service; import org.junit.Assert; import org.junit.Test; -import javax.validation.constraints.AssertTrue; import java.util.HashSet; import java.util.Set; diff --git a/fe/fe-core/src/test/java/org/apache/doris/system/HeartbeatMgrTest.java b/fe/fe-core/src/test/java/org/apache/doris/system/HeartbeatMgrTest.java index e6c6f035e3..00aea973a2 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/system/HeartbeatMgrTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/system/HeartbeatMgrTest.java @@ -20,10 +20,8 @@ package org.apache.doris.system; import mockit.Expectations; import org.apache.doris.catalog.Catalog; import org.apache.doris.catalog.FsBroker; -import org.apache.doris.common.Config; import org.apache.doris.common.GenericPool; import org.apache.doris.common.Pair; -import org.apache.doris.common.util.Util; import org.apache.doris.ha.FrontendNodeType; import org.apache.doris.system.HeartbeatMgr.BrokerHeartbeatHandler; import org.apache.doris.system.HeartbeatMgr.FrontendHeartbeatHandler; diff --git a/fe/fe-core/src/test/java/org/apache/doris/task/LoadPendingTaskTest.java b/fe/fe-core/src/test/java/org/apache/doris/task/LoadPendingTaskTest.java index 671f9a834d..624c2375d5 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/task/LoadPendingTaskTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/task/LoadPendingTaskTest.java @@ -25,7 +25,6 @@ import org.apache.doris.catalog.OlapTable; import org.apache.doris.catalog.Partition; import org.apache.doris.common.Config; import org.apache.doris.common.util.UnitTestUtil; -import org.apache.doris.load.DppConfig; import org.apache.doris.load.DppScheduler; import org.apache.doris.load.EtlSubmitResult; import org.apache.doris.load.Load; diff --git a/fe/fe-core/src/test/java/org/apache/doris/utframe/MockedBackendFactory.java b/fe/fe-core/src/test/java/org/apache/doris/utframe/MockedBackendFactory.java index bc3e7928fd..ca4da798ad 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/utframe/MockedBackendFactory.java +++ b/fe/fe-core/src/test/java/org/apache/doris/utframe/MockedBackendFactory.java @@ -278,7 +278,7 @@ public class MockedBackendFactory { @Override public long getTrashUsedCapacity() throws TException { - return 0l; + return 0L; } @Override diff --git a/fe/java-udf/src/test/java/org/apache/doris/udf/UdfExecutorTest.java b/fe/java-udf/src/test/java/org/apache/doris/udf/UdfExecutorTest.java index 6113d94e84..17e781c4c2 100644 --- a/fe/java-udf/src/test/java/org/apache/doris/udf/UdfExecutorTest.java +++ b/fe/java-udf/src/test/java/org/apache/doris/udf/UdfExecutorTest.java @@ -17,7 +17,16 @@ package org.apache.doris.udf; -import org.apache.doris.thrift.*; +import org.apache.doris.thrift.TFunction; +import org.apache.doris.thrift.TFunctionBinaryType; +import org.apache.doris.thrift.TFunctionName; +import org.apache.doris.thrift.TJavaUdfExecutorCtorParams; +import org.apache.doris.thrift.TPrimitiveType; +import org.apache.doris.thrift.TScalarFunction; +import org.apache.doris.thrift.TScalarType; +import org.apache.doris.thrift.TTypeDesc; +import org.apache.doris.thrift.TTypeNode; +import org.apache.doris.thrift.TTypeNodeType; import org.apache.thrift.TSerializer; import org.apache.thrift.protocol.TBinaryProtocol; import org.junit.Test; diff --git a/fe/pom.xml b/fe/pom.xml index 60bd5dec67..b263f81b79 100644 --- a/fe/pom.xml +++ b/fe/pom.xml @@ -156,6 +156,7 @@ under the License. <failsOnError>true</failsOnError> <linkXRef>false</linkXRef> <excludes>**/jmockit/**/*</excludes> + <includeTestSourceDirectory>true</includeTestSourceDirectory> </configuration> <executions> <execution> diff --git a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DorisRangePartitionerTest.java b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DorisRangePartitionerTest.java index 37addb7b49..c4f7d9bccf 100644 --- a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DorisRangePartitionerTest.java +++ b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DorisRangePartitionerTest.java @@ -18,16 +18,9 @@ package org.apache.doris.load.loadv2.dpp; -import org.apache.doris.load.loadv2.dpp.DorisRangePartitioner; - import org.apache.doris.load.loadv2.etl.EtlJobConfig; import org.junit.Assert; import org.junit.Test; -import mockit.Expectations; -import mockit.Injectable; -import mockit.Mock; -import mockit.MockUp; -import mockit.Mocked; import java.util.ArrayList; import java.util.List; @@ -141,4 +134,4 @@ public class DorisRangePartitionerTest { int id = rangePartitioner.getPartition(record); Assert.assertEquals(0, id); } -} \ No newline at end of file +} diff --git a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DppUtilsTest.java b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DppUtilsTest.java index 4db033f8b8..7b65067cc3 100644 --- a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DppUtilsTest.java +++ b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/DppUtilsTest.java @@ -18,23 +18,18 @@ package org.apache.doris.load.loadv2.dpp; -import io.netty.handler.codec.dns.DefaultDnsPtrRecord; import org.apache.doris.load.loadv2.etl.EtlJobConfig; import org.apache.spark.sql.types.DataTypes; import org.apache.spark.sql.types.DataType; -import org.apache.spark.sql.types.DataTypes; -import org.apache.spark.sql.types.StructField; import org.apache.spark.sql.types.StructType; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Date; import java.util.List; -import java.util.Map; import org.junit.Assert; import org.junit.Test; -import java.lang.Exception; public class DppUtilsTest { @@ -241,4 +236,4 @@ public class DppUtilsTest { Assert.assertTrue(false); } } -} \ No newline at end of file +} diff --git a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/MinimumCoverageRollupTreeBuilderTest.java b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/MinimumCoverageRollupTreeBuilderTest.java index 6e0e93e95e..e2083350d3 100644 --- a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/MinimumCoverageRollupTreeBuilderTest.java +++ b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/MinimumCoverageRollupTreeBuilderTest.java @@ -19,11 +19,9 @@ package org.apache.doris.load.loadv2.dpp; import org.apache.doris.load.loadv2.etl.EtlJobConfig; -import org.apache.doris.load.loadv2.dpp.MinimumCoverageRollupTreeBuilder; -import org.apache.doris.load.loadv2.dpp.RollupTreeNode; + import org.junit.Assert; import org.junit.Test; - import java.util.ArrayList; import java.util.List; @@ -108,4 +106,4 @@ public class MinimumCoverageRollupTreeBuilderTest { Assert.assertEquals(index2Node.level, 2); Assert.assertEquals(index2Node.children, null); } -} \ No newline at end of file +} diff --git a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/SparkDppTest.java b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/SparkDppTest.java index 9cec220eb6..c8a7b3a35c 100644 --- a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/SparkDppTest.java +++ b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/dpp/SparkDppTest.java @@ -18,7 +18,6 @@ package org.apache.doris.load.loadv2.dpp; import org.apache.doris.load.loadv2.etl.EtlJobConfig; -import org.apache.spark.sql.Row; import org.apache.spark.sql.RowFactory; import org.junit.Assert; import org.junit.Test; diff --git a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/etl/SparkEtlJobTest.java b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/etl/SparkEtlJobTest.java index 681e027f46..ebac60df8b 100644 --- a/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/etl/SparkEtlJobTest.java +++ b/fe/spark-dpp/src/test/java/org/apache/doris/load/loadv2/etl/SparkEtlJobTest.java @@ -149,4 +149,4 @@ public class SparkEtlJobTest { // check remove v2 bitmap_dict func mapping from file group column mappings Assert.assertFalse(table.fileGroups.get(0).columnMappings.containsKey("v2")); } -} \ No newline at end of file +} --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org