diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java index ee47ea5206..e8fac1ca4f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java @@ -3280,7 +3280,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { if (!Env.getCurrentEnv().isMaster()) { errorStatus.setStatusCode(TStatusCode.NOT_MASTER); errorStatus.addToErrorMsgs(NOT_MASTER_ERR_MSG); - LOG.error("failed to createPartition: {}", NOT_MASTER_ERR_MSG); + LOG.warn("failed to createPartition: {}", NOT_MASTER_ERR_MSG); return result; } @@ -3288,6 +3288,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { if (db == null) { errorStatus.setErrorMsgs(Lists.newArrayList(String.format("dbId=%d is not exists", dbId))); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } @@ -3296,6 +3297,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { errorStatus.setErrorMsgs( (Lists.newArrayList(String.format("dbId=%d tableId=%d is not exists", dbId, tableId)))); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } @@ -3303,12 +3305,14 @@ public class FrontendServiceImpl implements FrontendService.Iface { errorStatus.setErrorMsgs( Lists.newArrayList(String.format("dbId=%d tableId=%d is not olap table", dbId, tableId))); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } if (request.partitionValues == null) { errorStatus.setErrorMsgs(Lists.newArrayList("partitionValues should not null.")); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } @@ -3321,6 +3325,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { Lists.newArrayList( "Only support single partition of RANGE, partitionValues size should equal 1.")); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } partitionValues.add(request.partitionValues.get(i)); @@ -3332,6 +3337,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { } catch (AnalysisException ex) { errorStatus.setErrorMsgs(Lists.newArrayList(ex.getMessage())); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } @@ -3345,6 +3351,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { LOG.warn(errorMessage); errorStatus.setErrorMsgs(Lists.newArrayList(errorMessage)); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } @@ -3357,6 +3364,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { errorStatus.setErrorMsgs( Lists.newArrayList(String.format("create partition failed. error:%s", e.getMessage()))); result.setStatus(errorStatus); + LOG.warn("send create partition error status: {}", result); return result; } } diff --git a/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy b/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy index e01cd127a5..72549e18d9 100644 --- a/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy +++ b/regression-test/suites/partition_p2/auto_partition/diff_data/stress_test_diff_date_list.groovy @@ -21,7 +21,7 @@ import java.nio.file.Paths import java.net.URL import java.io.File -suite("stress_test_diff_date_list") { +suite("stress_test_diff_date_list", "p2,nonConcurrent") { sql """ADMIN SET FRONTEND CONFIG ('max_auto_partition_num' = '10000000')""" diff --git a/regression-test/suites/partition_p2/auto_partition/high_concur_load/stress_test_high_concurrency_load.groovy b/regression-test/suites/partition_p2/auto_partition/high_concur_load/stress_test_high_concurrency_load.groovy index abe7130150..124088047f 100644 --- a/regression-test/suites/partition_p2/auto_partition/high_concur_load/stress_test_high_concurrency_load.groovy +++ b/regression-test/suites/partition_p2/auto_partition/high_concur_load/stress_test_high_concurrency_load.groovy @@ -21,7 +21,7 @@ import java.nio.file.Paths import java.net.URL import java.io.File -suite("stress_test_high_concurrency_load") { +suite("stress_test_high_concurrency_load", "p2,nonConcurrent") { sql """ADMIN SET FRONTEND CONFIG ('max_auto_partition_num' = '10000000')""" diff --git a/regression-test/suites/partition_p2/auto_partition/same_data/stress_test_same_date_range.groovy b/regression-test/suites/partition_p2/auto_partition/same_data/stress_test_same_date_range.groovy index 931856f8d2..e081e3bf09 100644 --- a/regression-test/suites/partition_p2/auto_partition/same_data/stress_test_same_date_range.groovy +++ b/regression-test/suites/partition_p2/auto_partition/same_data/stress_test_same_date_range.groovy @@ -21,7 +21,7 @@ import java.nio.file.Paths import java.net.URL import java.io.File -suite("stress_test_same_date_range") { +suite("stress_test_same_date_range", "p2,nonConcurrent") { sql """ADMIN SET FRONTEND CONFIG ('max_auto_partition_num' = '10000000')""" diff --git a/regression-test/suites/partition_p2/auto_partition/two_stream_load/stress_test_two_stream_load.groovy b/regression-test/suites/partition_p2/auto_partition/two_stream_load/stress_test_two_stream_load.groovy index f137e74820..bd0f7d1aa2 100644 --- a/regression-test/suites/partition_p2/auto_partition/two_stream_load/stress_test_two_stream_load.groovy +++ b/regression-test/suites/partition_p2/auto_partition/two_stream_load/stress_test_two_stream_load.groovy @@ -21,7 +21,7 @@ import java.nio.file.Paths import java.net.URL import java.io.File -suite("stress_test_two_stream_load") { +suite("stress_test_two_stream_load", "p2,nonConcurrent") { sql """ADMIN SET FRONTEND CONFIG ('max_auto_partition_num' = '10000000')"""