This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 7508380e226 branch-3.1: [test](inverted index) make
test_cumulative_compaction_with_format_v2 regression case more stable #53756
(#53770)
7508380e226 is described below
commit 7508380e226569e1734beac6644f98f9ff374048
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jul 24 10:36:13 2025 +0800
branch-3.1: [test](inverted index) make
test_cumulative_compaction_with_format_v2 regression case more stable #53756
(#53770)
Cherry-picked from #53756
Co-authored-by: airborne12 <[email protected]>
---
...est_cumulative_compaction_with_format_v2.groovy | 31 +++++++++++++++++++++-
1 file changed, 30 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
b/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
index eff05b1fd8d..6e39fa09fcd 100644
---
a/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
+++
b/regression-test/suites/inverted_index_p0/index_format_v2/test_cumulative_compaction_with_format_v2.groovy
@@ -163,13 +163,42 @@ suite("test_cumulative_compaction_with_format_v2",
"inverted_index_format_v2") {
def tablets = sql_return_maparray """ show tablets from ${tableName};
"""
// trigger compactions for all tablets in ${tableName}
- trigger_and_wait_compaction(tableName, "cumulative")
+ //trigger_and_wait_compaction(tableName, "cumulative")
// wait for all compactions done
for (def tablet in tablets) {
String tablet_id = tablet.TabletId
backend_id = tablet.BackendId
String ip = backendId_to_backendIP.get(backend_id)
String port = backendId_to_backendHttpPort.get(backend_id)
+ be_show_tablet_status(ip, port, tablet_id)
+ (code, out, err) = be_show_tablet_status(ip, port, tablet_id)
+ logger.info("Run show: code=" + code + ", out=" + out + ", err=" +
err)
+ assertTrue(out.contains("[0-1]"))
+ assertTrue(out.contains("[2-2]"))
+ assertTrue(out.contains("[3-3]"))
+ assertTrue(out.contains("[4-4]"))
+ assertTrue(out.contains("[5-5]"))
+ assertTrue(out.contains("[6-6]"))
+ assertTrue(out.contains("[7-7]"))
+ assertTrue(out.contains("[8-8]"))
+ assertTrue(out.contains("[9-9]"))
+ logger.info("run compaction:" + tablet_id)
+ (code, out, err) = be_run_cumulative_compaction(ip, port,
tablet_id)
+ logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
+ boolean running = true
+ do {
+ Thread.sleep(100)
+ (code, out, err) = be_get_compaction_status(ip, port,
tablet_id)
+ logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
+ assertEquals(code, 0)
+ def compactionStatus = parseJson(out.trim())
+ assertEquals("success", compactionStatus.status.toLowerCase())
+ running = compactionStatus.run_status
+ } while (running)
+ (code, out, err) = be_show_tablet_status(ip, port, tablet_id)
+ logger.info("Run show: code=" + code + ", out=" + out + ", err=" +
err)
+ assertTrue(out.contains("[0-1]"))
+ assertTrue(out.contains("[2-9]"))
int segment_count = calc_segment_count(tablet)
logger.info("TabletId: " + tablet_id + ", segment_count: " +
segment_count)
check_nested_index_file(ip, port, tablet_id, 2, 3, "V2")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
