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 8c690fce0b5 branch-3.1: [fix](test) make test_writer_fault_injection
do not affected by other cases #54369 (#54431)
8c690fce0b5 is described below
commit 8c690fce0b5f78cf04d5447886a59a5f26df1650
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Aug 7 20:22:02 2025 +0800
branch-3.1: [fix](test) make test_writer_fault_injection do not affected by
other cases #54369 (#54431)
Cherry-picked from #54369
Co-authored-by: hui lai <[email protected]>
---
.../suites/fault_injection_p0/test_writer_fault_injection.groovy | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/regression-test/suites/fault_injection_p0/test_writer_fault_injection.groovy
b/regression-test/suites/fault_injection_p0/test_writer_fault_injection.groovy
index 351c009dd85..47c9da8d009 100644
---
a/regression-test/suites/fault_injection_p0/test_writer_fault_injection.groovy
+++
b/regression-test/suites/fault_injection_p0/test_writer_fault_injection.groovy
@@ -22,7 +22,7 @@ suite("test_writer_fault_injection", "nonConcurrent") {
sql """ set enable_memtable_on_sink_node=false """
try {
sql """
- CREATE TABLE IF NOT EXISTS `baseall` (
+ CREATE TABLE IF NOT EXISTS `test_writer_fault_injection_source` (
`k0` boolean null comment "",
`k1` tinyint(4) null comment "",
`k2` smallint(6) null comment "",
@@ -41,7 +41,7 @@ suite("test_writer_fault_injection", "nonConcurrent") {
DISTRIBUTED BY HASH(`k1`) BUCKETS 5 properties("replication_num" =
"1")
"""
sql """
- CREATE TABLE IF NOT EXISTS `test` (
+ CREATE TABLE IF NOT EXISTS `test_writer_fault_injection_dest` (
`k0` boolean null comment "",
`k1` tinyint(4) null comment "",
`k2` smallint(6) null comment "",
@@ -62,7 +62,7 @@ suite("test_writer_fault_injection", "nonConcurrent") {
GetDebugPoint().clearDebugPointsForAllBEs()
streamLoad {
- table "baseall"
+ table "test_writer_fault_injection_source"
db "regression_test_fault_injection_p0"
set 'column_separator', ','
file "baseall.txt"
@@ -71,7 +71,7 @@ suite("test_writer_fault_injection", "nonConcurrent") {
def load_with_injection = { injection, error_msg="", success=false->
try {
GetDebugPoint().enableDebugPointForAllBEs(injection)
- sql "insert into test select * from baseall where k1 <= 3"
+ sql "insert into test_writer_fault_injection_dest select *
from test_writer_fault_injection_source where k1 <= 3"
assertTrue(success, String.format("expected Exception '%s',
actual success", error_msg))
} catch(Exception e) {
logger.info(e.getMessage())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
