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 f6c120c3c67 branch-3.1: [fix](case) fix test_flush_editlog_exception
#55210 (#55238)
f6c120c3c67 is described below
commit f6c120c3c6723275e534a0ee490ece79710ec31e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 25 17:16:46 2025 +0800
branch-3.1: [fix](case) fix test_flush_editlog_exception #55210 (#55238)
Cherry-picked from #55210
Co-authored-by: Yongqiang YANG <[email protected]>
---
.../test_flush_editlog_exception.groovy | 52 ++++++++--------------
1 file changed, 19 insertions(+), 33 deletions(-)
diff --git
a/regression-test/suites/fault_injection_p0/test_flush_editlog_exception.groovy
b/regression-test/suites/fault_injection_p0/test_flush_editlog_exception.groovy
index 43196693890..54e09d626a1 100644
---
a/regression-test/suites/fault_injection_p0/test_flush_editlog_exception.groovy
+++
b/regression-test/suites/fault_injection_p0/test_flush_editlog_exception.groovy
@@ -32,39 +32,25 @@ suite("test_flush_editlog_exception", "docker") {
GetDebugPoint().enableDebugPointForAllFEs('EditLog.flushEditLog.exception')
- sql """
- CREATE TABLE IF NOT EXISTS ${tableName} (
- `user_id` bigint default 999,
- `group_id` bigint,
- `id` bigint,
- `vv` variant,
- INDEX idx_col1 (user_id) USING INVERTED
- ) ENGINE=OLAP
- UNIQUE KEY(user_id, group_id)
- DISTRIBUTED BY HASH (user_id) BUCKETS 1
- PROPERTIES(
- "store_row_column" = "true",
- "replication_num" = "1"
- );
- """
-
- // Wait until SELECT returns error (i.e., Doris FE process exits due
to flushEditLog exception)
- int maxWaitMs = 10000
- int intervalMs = 200
- long startTime = System.currentTimeMillis()
- boolean gotError = false
- while (true) {
- try {
- sql "SELECT * from ${tableName}"
- } catch (Exception e) {
- gotError = true
- break
- }
- if (System.currentTimeMillis() - startTime > maxWaitMs) {
- throw new IllegalStateException("Timeout waiting for SELECT to
return error")
- }
- Thread.sleep(intervalMs)
+ try {
+ sql """
+ CREATE TABLE IF NOT EXISTS ${tableName} (
+ `user_id` bigint default 999,
+ `group_id` bigint,
+ `id` bigint,
+ `vv` variant,
+ INDEX idx_col1 (user_id) USING INVERTED
+ ) ENGINE=OLAP
+ UNIQUE KEY(user_id, group_id)
+ DISTRIBUTED BY HASH (user_id) BUCKETS 1
+ PROPERTIES(
+ "store_row_column" = "true",
+ "replication_num" = "1"
+ );
+ """
+ } catch (Exception e) {
+ assert e.message.contains("Communications link failure")
}
- assert gotError
}
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
