This is an automated email from the ASF dual-hosted git repository.
gavinchou 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 c44e327dc24 [fix](regression) Stabilize base compaction E-808 case
(#65320)
c44e327dc24 is described below
commit c44e327dc2405b5319cc7e51a7051dec66b70428
Author: Jamie <[email protected]>
AuthorDate: Wed Aug 5 16:11:34 2026 +0800
[fix](regression) Stabilize base compaction E-808 case (#65320)
Problem Summary: The compaction regression case expected the manual base
compaction HTTP response to synchronously contain E-808. The backend
only waits 2 seconds for manual base compaction before returning a
successful trigger response, while the background compaction task can
record BE_NO_SUITABLE_VERSION later. This makes the case flaky when the
expected E-808 is written after the HTTP response. The case now accepts
a synchronous E-808 response and otherwise polls the tablet compaction
status until the background task records E-808.
---
...paction_with_dup_key_max_file_size_limit.groovy | 28 +++++++++++++++++++---
1 file changed, 25 insertions(+), 3 deletions(-)
diff --git
a/regression-test/suites/compaction/test_base_compaction_with_dup_key_max_file_size_limit.groovy
b/regression-test/suites/compaction/test_base_compaction_with_dup_key_max_file_size_limit.groovy
index a006ea406d6..6f5e3c4af1f 100644
---
a/regression-test/suites/compaction/test_base_compaction_with_dup_key_max_file_size_limit.groovy
+++
b/regression-test/suites/compaction/test_base_compaction_with_dup_key_max_file_size_limit.groovy
@@ -109,6 +109,13 @@
suite("test_base_compaction_with_dup_key_max_file_size_limit", "p2") {
return out
}
+ def getBaseCompactionStatus = { be_host, be_http_port, tablet_id ->
+ def (statusCode, statusOut, statusErr) =
be_show_tablet_status(be_host, be_http_port, tablet_id)
+ logger.info("Show compaction status: code=" + statusCode + ",
out=" + statusOut + ", err=" + statusErr)
+ assertEquals(0, statusCode)
+ return parseJson(statusOut.trim())["last base status"].toString()
+ }
+
sql """ DROP TABLE IF EXISTS ${tableName}; """
sql """
CREATE TABLE IF NOT EXISTS ${tableName} (
@@ -183,9 +190,24 @@
suite("test_base_compaction_with_dup_key_max_file_size_limit", "p2") {
// [0-3] 2G nooverlapping
// [4-4] 1G nooverlapping
// cp: 5
- // WHAT: replace with plugin and handle fail?
-
assertTrue(triggerCompaction(backendId_to_backendIP[trigger_backend_id],
backendId_to_backendHttpPort[trigger_backend_id],
- "base", tablet_id).contains("E-808"));
+ String trigger_backend_host =
backendId_to_backendIP[trigger_backend_id]
+ String trigger_backend_http_port =
backendId_to_backendHttpPort[trigger_backend_id]
+ def baseCompactionResult = triggerCompaction(trigger_backend_host,
trigger_backend_http_port,
+ "base", tablet_id)
+ String lastBaseStatus = baseCompactionResult
+ if (!baseCompactionResult.contains("E-808")) {
+ // Manual compaction may return success after its 2s async wait
before
+ // the background task records BE_NO_SUITABLE_VERSION.
+ for (int i = 0; i < 300; i++) {
+ lastBaseStatus = getBaseCompactionStatus(trigger_backend_host,
trigger_backend_http_port, tablet_id)
+ if (lastBaseStatus.contains("E-808")) {
+ break
+ }
+ sleep(1000)
+ }
+ }
+ assertTrue(lastBaseStatus.contains("E-808"),
+ "base compaction result does not contain E-808,
result=${baseCompactionResult}, lastBaseStatus=${lastBaseStatus}");
def rowCount = sql "select count(*) from ${tableName}"
assertTrue(rowCount[0][0] != rows)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
