This is an automated email from the ASF dual-hosted git repository.
liaoxin01 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new e9165fa0495 [test](regression) Remove unsupported non-cloud
auto-partition idempotence case (#68070)
e9165fa0495 is described below
commit e9165fa04959b8990ddf0afdfb8e8783ed39fcd8
Author: Refrain <[email protected]>
AuthorDate: Sat Oct 10 10:40:19 2026 +0800
[test](regression) Remove unsupported non-cloud auto-partition idempotence
case (#68070)
---
.../test_auto_partition_idempotence.groovy | 96 ----------------------
1 file changed, 96 deletions(-)
diff --git
a/regression-test/suites/partition_p0/auto_partition/test_auto_partition_idempotence.groovy
b/regression-test/suites/partition_p0/auto_partition/test_auto_partition_idempotence.groovy
deleted file mode 100644
index 7331c2bb832..00000000000
---
a/regression-test/suites/partition_p0/auto_partition/test_auto_partition_idempotence.groovy
+++ /dev/null
@@ -1,96 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import org.apache.doris.regression.suite.ClusterOptions
-import groovy.json.JsonSlurper
-
-/*
-Test Description:
- We create a two-tablet table with skewed data, where one tablet has 1 row
and the other tablet has 20,000 rows.
- By running "insert into ... select ..." we trigger two instances, which
will send the same create-partition RPC to the FE.
-
- Enabling MockRebalance will count how many times createPartition is
called. On the second time this RPC is received,
- it will deliberately return a different tablet distribution to check
whether the tablet distribution cache is working.
-*/
-
-
-suite('test_create_partition_idempotence_non_cloud', 'docker') {
- // non_cloud mode
- // (Refrain) Because with storage-compute separation, the BE actually
tracks the tablet id, so it's hard to use mock tests
- // to verify the "rowset already exists" problem in the reverse case.
Therefore, we only verify the positive case here.
- def options= new ClusterOptions()
- options.feConfigs += [
- 'enable_debug_points=true',
- 'sys_log_verbose_modules = org.apache.doris',
- ]
- options.cloudMode = false
- options.beNum = 3
-
- docker(options) {
- def sourceTable = "test_partition_source_table"
- sql "DROP TABLE IF EXISTS ${sourceTable}"
- sql """
- CREATE TABLE ${sourceTable} (
- `date` DATE NOT NULL,
- `id` INT,
- `value` VARCHAR(100)
- )
- DISTRIBUTED BY HASH(`date`) BUCKETS 2
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """ INSERT INTO ${sourceTable} VALUES ("2025-11-04", 1, "test1");
"""
- sql """ INSERT INTO ${sourceTable} SELECT "2025-11-04", number, "test"
FROM numbers("number" = "20000"); """
-
- def tableName = "test_partition_idempotence_table"
- sql "DROP TABLE IF EXISTS ${tableName}"
- sql """
- CREATE TABLE ${tableName} (
- `date` DATE NOT NULL,
- `id` INT,
- `value` VARCHAR(100)
- )
- AUTO PARTITION BY RANGE (date_trunc(`date`, 'day')) ()
- DISTRIBUTED BY HASH(id) BUCKETS 4
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """ set parallel_pipeline_task_num = 2 """
- sql """ set load_stream_per_node = 2 """
-
-
GetDebugPoint().enableDebugPointForAllFEs("FE.FrontendServiceImpl.createPartition.MockRebalance")
- try {
- sql """ INSERT INTO ${tableName} SELECT * FROM ${sourceTable}; """
-
- def result = sql "SELECT count(DISTINCT `date`) FROM ${tableName}"
- assertEquals(1, result[0][0])
-
- def count = sql "SELECT count(*) FROM ${tableName}"
- assertEquals(20001, count[0][0])
-
- } catch (Exception e) {
- logger.error("failed: ${e.message}")
- throw e
- } finally {
-
GetDebugPoint().disableDebugPointForAllFEs("FE.FrontendServiceImpl.createPartition.MockRebalance")
- }
- }
-}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
