This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new a4b7179c5cb [fix](regression) retry long stream load inputs (#65337)
a4b7179c5cb is described below
commit a4b7179c5cbea40a8622d1e286637dbea890f796
Author: shuke <[email protected]>
AuthorDate: Fri Jul 10 10:05:16 2026 +0800
[fix](regression) retry long stream load inputs (#65337)
## Summary
- Enable retry for long-running stream load cases that read large
TPCH/TPCDS or large-data files from S3/HTTP.
- Cover the flaky branch-4.1 P2 compaction case
test_base_compaction_no_value and related long import cases.
## Testing
- git diff --check
- Static scan confirmed no matching long S3 streamLoad block remains
without retry.
---
.../suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy | 1 +
.../cold_heat_separation_p2/create_table_use_partition_policy.groovy | 1 +
.../create_table_use_partition_policy_by_hdfs.groovy | 1 +
.../suites/cold_heat_separation_p2/create_table_use_policy.groovy | 1 +
.../cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy | 1 +
.../suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy | 1 +
.../cold_heat_separation_p2/modify_replica_use_partition.groovy | 1 +
.../modify_replica_use_partition_by_hdfs.groovy | 1 +
.../cold_heat_separation_p2/table_modify_resouce_and_policy.groovy | 1 +
.../table_modify_resouce_and_policy_by_hdfs.groovy | 1 +
regression-test/suites/compaction/test_base_compaction.groovy | 3 +++
.../suites/compaction/test_base_compaction_no_value.groovy | 3 +++
.../compaction/test_filecache_with_base_compaction_thresthold.groovy | 4 ++++
.../test_group_commit_http_stream_lineitem_multiple_client.groovy | 1 +
.../test_group_commit_http_stream_lineitem_multiple_table.groovy | 1 +
.../insert_p2/test_group_commit_http_stream_lineitem_normal.groovy | 1 +
.../test_group_commit_http_stream_lineitem_schema_change.groovy | 2 ++
.../test_group_commit_stream_load_lineitem_multiple_client.groovy | 1 +
.../test_group_commit_stream_load_lineitem_multiple_table.groovy | 1 +
.../insert_p2/test_group_commit_stream_load_lineitem_normal.groovy | 1 +
.../test_group_commit_stream_load_lineitem_schema_change.groovy | 1 +
.../transaction/txn_insert_concurrent_insert_aggregate.groovy | 1 +
.../transaction/txn_insert_concurrent_insert_duplicate.groovy | 1 +
.../insert_p2/transaction/txn_insert_concurrent_insert_mor.groovy | 1 +
.../insert_p2/transaction/txn_insert_concurrent_insert_mow.groovy | 1 +
.../insert_p2/transaction/txn_insert_concurrent_insert_ud.groovy | 1 +
.../insert_p2/transaction/txn_insert_concurrent_insert_update.groovy | 1 +
.../suites/insert_p2/transaction/txn_insert_with_schema_change.groovy | 1 +
regression-test/suites/inverted_index_p1/tpcds_sf1_index/load.groovy | 1 +
regression-test/suites/load_p2/test_large_data_by_rpc.groovy | 1 +
.../mv/create_part_and_up/create_commit_mtmv_many_task.groovy | 1 +
regression-test/suites/tpcds_sf1_p1/load.groovy | 1 +
regression-test/suites/tpcds_sf1_p2/load.groovy | 1 +
regression-test/suites/tpch_sf1_p2/load.groovy | 2 ++
regression-test/suites/tpch_sf1_unique_p2/load.groovy | 2 ++
35 files changed, 45 insertions(+)
diff --git
a/regression-test/suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy
b/regression-test/suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy
index 7ccf118b65f..c66ee426a99 100644
---
a/regression-test/suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy
+++
b/regression-test/suites/cloud_p0/cache/read_from_peer/test_read_from_peer.groovy
@@ -152,6 +152,7 @@ suite('test_read_from_peer', 'docker') {
// file """store_sales.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
setFeAddr cluster.getAllFrontends().get(0).host,
cluster.getAllFrontends().get(0).httpPort
check { res, exception, startTime, endTime ->
diff --git
a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy.groovy
b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy.groovy
index 25eaa5e7a30..1c76f0dfb41 100644
---
a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy.groovy
@@ -70,6 +70,7 @@ suite("create_table_use_partition_policy") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy
b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy
index 8004b2dc772..04552a78c58 100644
---
a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy
@@ -73,6 +73,7 @@ suite("create_table_use_partition_policy_by_hdfs") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy.groovy
b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy.groovy
index f7b024795f5..5c8cb7190a3 100644
---
a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy.groovy
@@ -70,6 +70,7 @@ suite("create_table_use_policy") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy
b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy
index 43e9e26cc94..ee0ee132d37 100644
---
a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy
@@ -73,6 +73,7 @@ suite("create_table_use_policy_by_hdfs") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy
b/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy
index 089c89b72d5..00fcaa21899 100644
---
a/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy
@@ -73,6 +73,7 @@ suite("load_colddata_to_hdfs") {
// also, you can stream load a http stream, e.g.
http://xxx/some.csv
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition.groovy
b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition.groovy
index b66ced914c6..98287da9b6e 100644
---
a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition.groovy
@@ -88,6 +88,7 @@ try {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy
b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy
index 6f69d913bef..10aa955fcbb 100644
---
a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy
@@ -92,6 +92,7 @@ try {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy.groovy
b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy.groovy
index ec8fcc8f255..94600dbb281 100644
---
a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy.groovy
@@ -70,6 +70,7 @@ suite("table_modify_resouce") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy
b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy
index 574d9ef44fc..0feda8f0845 100644
---
a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy
+++
b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy
@@ -73,6 +73,7 @@ suite("table_modify_resouce_by_hdfs") {
file
"""${getS3Url()}/regression/tpch/sf1/lineitem.csv.split${partnum}.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git a/regression-test/suites/compaction/test_base_compaction.groovy
b/regression-test/suites/compaction/test_base_compaction.groovy
index 5600017b138..ac54a3ae92c 100644
--- a/regression-test/suites/compaction/test_base_compaction.groovy
+++ b/regression-test/suites/compaction/test_base_compaction.groovy
@@ -81,6 +81,7 @@ suite("test_base_compaction", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
@@ -116,6 +117,7 @@ suite("test_base_compaction", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
@@ -156,6 +158,7 @@ suite("test_base_compaction", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split00.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/compaction/test_base_compaction_no_value.groovy
b/regression-test/suites/compaction/test_base_compaction_no_value.groovy
index 44a833bf5bb..e71f03f970d 100644
--- a/regression-test/suites/compaction/test_base_compaction_no_value.groovy
+++ b/regression-test/suites/compaction/test_base_compaction_no_value.groovy
@@ -81,6 +81,7 @@ suite("test_base_compaction_no_value", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
@@ -116,6 +117,7 @@ suite("test_base_compaction_no_value", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
@@ -156,6 +158,7 @@ suite("test_base_compaction_no_value", "p2") {
file """${getS3Url()}/regression/tpch/sf1/lineitem.csv.split00.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status, and
NumberTotalRows == NumberLoadedRows
diff --git
a/regression-test/suites/compaction/test_filecache_with_base_compaction_thresthold.groovy
b/regression-test/suites/compaction/test_filecache_with_base_compaction_thresthold.groovy
index 90a0053ce18..da4f1a2167a 100644
---
a/regression-test/suites/compaction/test_filecache_with_base_compaction_thresthold.groovy
+++
b/regression-test/suites/compaction/test_filecache_with_base_compaction_thresthold.groovy
@@ -195,6 +195,7 @@ suite("test_filecache_with_base_compaction_thresthold",
"docker") {
file """${getS3Url()}/regression/tpcds/sf1/store_sales.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { res, exception, startTime, endTime ->
if (exception != null) {
throw exception
@@ -356,6 +357,7 @@ suite("test_filecache_with_base_compaction_thresthold",
"docker") {
file """${getS3Url()}/regression/tpcds/sf1/store_sales.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { res, exception, startTime, endTime ->
if (exception != null) {
throw exception
@@ -519,6 +521,7 @@ suite("test_filecache_with_base_compaction_thresthold",
"docker") {
file """${getS3Url()}/regression/tpcds/sf1/store_sales.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { res, exception, startTime, endTime ->
if (exception != null) {
throw exception
@@ -681,6 +684,7 @@ suite("test_filecache_with_base_compaction_thresthold",
"docker") {
file """${getS3Url()}/regression/tpcds/sf1/store_sales.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { res, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_client.groovy
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_client.groovy
index a6b05dcede1..62d2a63ebb3 100644
---
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_client.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_client.groovy
@@ -105,6 +105,7 @@ l_shipmode,l_comment) select c1, c2, c3, c4, c5, c6, c7,
c8, c9, c10, c11, c12,
set 'group_commit', 'async_mode'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl.""" + i
+ retryIfHttpError true
unset 'label'
check { result, exception, startTime, endTime ->
diff --git
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_table.groovy
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_table.groovy
index b73954aca58..1b4bb87bf0a 100644
---
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_table.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_multiple_table.groovy
@@ -99,6 +99,7 @@ l_shipmode,l_comment) select c1, c2, c3, c4, c5, c6, c7, c8,
c9, c10, c11, c12,
set 'group_commit', 'async_mode'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl.""" + i
+ retryIfHttpError true
unset 'label'
check { result, exception, startTime, endTime ->
diff --git
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_normal.groovy
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_normal.groovy
index 44d9a0ff94b..eb8fe9ed1c8 100644
---
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_normal.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_normal.groovy
@@ -98,6 +98,7 @@ l_shipmode,l_comment) select c1, c2, c3, c4, c5, c6, c7, c8,
c9, c10, c11, c12,
set 'group_commit', 'async_mode'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl."""
+ i
+ retryIfHttpError true
unset 'label'
check { result, exception, startTime, endTime ->
diff --git
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_schema_change.groovy
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_schema_change.groovy
index e1faff07536..1fcc7ea8b86 100644
---
a/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_schema_change.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_http_stream_lineitem_schema_change.groovy
@@ -168,6 +168,7 @@ l_shipmode,l_comment) select c1, c2, c3, c4, c5, c6, c7,
c8, c9, c10, c11, c12,
set 'group_commit', 'async_mode'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl."""
+ i
+ retryIfHttpError true
unset 'label'
check { result, exception, startTime, endTime ->
@@ -197,6 +198,7 @@ l_comment) select c1, c2, c3, c4, c5, c6, c7, c8, c9, c10,
c11, c12, c14, c15, c
set 'group_commit', 'async_mode'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl.""" + i
+ retryIfHttpError true
unset 'label'
check { result, exception, startTime, endTime ->
diff --git
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_client.groovy
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_client.groovy
index 55606896944..8ea7e8c1604 100644
---
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_client.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_client.groovy
@@ -103,6 +103,7 @@ PROPERTIES (
set 'group_commit', 'async_mode'
unset 'label'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl.""" + i
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
checkStreamLoadResult(exception, result, rowCountArray[i - 1],
rowCountArray[i - 1], 0, 0)
diff --git
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_table.groovy
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_table.groovy
index 7e7289b61f0..886353e1c1d 100644
---
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_table.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_multiple_table.groovy
@@ -97,6 +97,7 @@ PROPERTIES (
set 'group_commit', 'async_mode'
unset 'label'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl.""" + i
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
checkStreamLoadResult(exception, result, rowCountArray[i - 1],
rowCountArray[i - 1], 0, 0)
diff --git
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_normal.groovy
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_normal.groovy
index 83784555ca8..188af0a7c6a 100644
---
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_normal.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_normal.groovy
@@ -96,6 +96,7 @@ l_tax, l_returnflag,l_linestatus,
l_shipdate,l_commitdate,l_receiptdate,l_shipin
set 'group_commit', 'async_mode'
unset 'label'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl."""
+ i
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
checkStreamLoadResult(exception, result,
rowCountArray[i - 1], rowCountArray[i - 1], 0, 0)
diff --git
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_schema_change.groovy
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_schema_change.groovy
index 93eb2283f20..1b276307080 100644
---
a/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_schema_change.groovy
+++
b/regression-test/suites/insert_p2/test_group_commit_stream_load_lineitem_schema_change.groovy
@@ -166,6 +166,7 @@ PROPERTIES (
set 'group_commit', 'async_mode'
unset 'label'
file """${getS3Url()}/regression/tpch/sf1/lineitem.tbl."""
+ i
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
checkStreamLoadResult(exception, result,
rowCountArray[i - 1], rowCountArray[i - 1], 0, 0)
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_aggregate.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_aggregate.groovy
index fa57c550118..16ac3bfe8e8 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_aggregate.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_aggregate.groovy
@@ -66,6 +66,7 @@ suite("txn_insert_concurrent_insert_aggregate") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_duplicate.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_duplicate.groovy
index e771078f1fb..085d7c0b18e 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_duplicate.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_duplicate.groovy
@@ -66,6 +66,7 @@ suite("txn_insert_concurrent_insert_duplicate") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mor.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mor.groovy
index 418992835d0..3dea964c139 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mor.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mor.groovy
@@ -67,6 +67,7 @@ suite("txn_insert_concurrent_insert_mor") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mow.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mow.groovy
index 4d6e297cac9..bebfb1edf24 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mow.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_mow.groovy
@@ -66,6 +66,7 @@ suite("txn_insert_concurrent_insert_mow") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_ud.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_ud.groovy
index d0b27641c64..05e1077a658 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_ud.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_ud.groovy
@@ -68,6 +68,7 @@ suite("txn_insert_concurrent_insert_ud") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_update.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_update.groovy
index eba69918660..335b64af07a 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_update.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_concurrent_insert_update.groovy
@@ -69,6 +69,7 @@ suite("txn_insert_concurrent_insert_update") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/insert_p2/transaction/txn_insert_with_schema_change.groovy
b/regression-test/suites/insert_p2/transaction/txn_insert_with_schema_change.groovy
index 34b859b5e80..dffdc9c301a 100644
---
a/regression-test/suites/insert_p2/transaction/txn_insert_with_schema_change.groovy
+++
b/regression-test/suites/insert_p2/transaction/txn_insert_with_schema_change.groovy
@@ -69,6 +69,7 @@ suite("txn_insert_with_schema_change") {
set 'compress_type', 'GZ'
file """${getS3Url()}/regression/tpch/sf1/${file_name}"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
throw exception
diff --git
a/regression-test/suites/inverted_index_p1/tpcds_sf1_index/load.groovy
b/regression-test/suites/inverted_index_p1/tpcds_sf1_index/load.groovy
index cef01fb4271..8035f0acb89 100644
--- a/regression-test/suites/inverted_index_p1/tpcds_sf1_index/load.groovy
+++ b/regression-test/suites/inverted_index_p1/tpcds_sf1_index/load.groovy
@@ -82,6 +82,7 @@ suite("load") {
file """${getS3Url()}/regression/tpcds/sf1/${tableName}.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git a/regression-test/suites/load_p2/test_large_data_by_rpc.groovy
b/regression-test/suites/load_p2/test_large_data_by_rpc.groovy
index 4c470ce08d6..58710836030 100644
--- a/regression-test/suites/load_p2/test_large_data_by_rpc.groovy
+++ b/regression-test/suites/load_p2/test_large_data_by_rpc.groovy
@@ -50,6 +50,7 @@ suite("test_large_data_by_rpc", "p2") {
file """${getS3Url()}/regression/load/data/large_data_by_rpc.csv.gz"""
time 30000
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
diff --git
a/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
b/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
index db4acfafee1..4cd23cecc3f 100644
---
a/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
+++
b/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
@@ -79,6 +79,7 @@ suite("create_commit_mtmv_many_tasks", "p2") {
table table_name
set 'column_separator', '|'
file """${getS3Url() + '/regression/tpch/sf1/'}${src_file_name}"""
+ retryIfHttpError true
check { result, exception, startTime, endTime ->
if (exception != null) {
diff --git a/regression-test/suites/tpcds_sf1_p1/load.groovy
b/regression-test/suites/tpcds_sf1_p1/load.groovy
index cef01fb4271..8035f0acb89 100644
--- a/regression-test/suites/tpcds_sf1_p1/load.groovy
+++ b/regression-test/suites/tpcds_sf1_p1/load.groovy
@@ -82,6 +82,7 @@ suite("load") {
file """${getS3Url()}/regression/tpcds/sf1/${tableName}.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git a/regression-test/suites/tpcds_sf1_p2/load.groovy
b/regression-test/suites/tpcds_sf1_p2/load.groovy
index cd5ade245a1..0ab8475031d 100644
--- a/regression-test/suites/tpcds_sf1_p2/load.groovy
+++ b/regression-test/suites/tpcds_sf1_p2/load.groovy
@@ -51,6 +51,7 @@ suite("load") {
file """${getS3Url()}/regression/tpcds/sf1/${tableName}.dat.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git a/regression-test/suites/tpch_sf1_p2/load.groovy
b/regression-test/suites/tpch_sf1_p2/load.groovy
index ee397e04013..00f0a8a6039 100644
--- a/regression-test/suites/tpch_sf1_p2/load.groovy
+++ b/regression-test/suites/tpch_sf1_p2/load.groovy
@@ -57,6 +57,7 @@ suite("load") {
file
"""${getS3Url()}/regression/tpch/sf1/${tableName}.csv.split00.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
@@ -92,6 +93,7 @@ suite("load") {
file
"""${getS3Url()}/regression/tpch/sf1/${tableName}.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
diff --git a/regression-test/suites/tpch_sf1_unique_p2/load.groovy
b/regression-test/suites/tpch_sf1_unique_p2/load.groovy
index 7248fa22928..d8a0c83aa4b 100644
--- a/regression-test/suites/tpch_sf1_unique_p2/load.groovy
+++ b/regression-test/suites/tpch_sf1_unique_p2/load.groovy
@@ -47,6 +47,7 @@ suite("load") {
file
"""${getS3Url()}/regression/tpch/sf1/${tableName}.csv.split00.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
@@ -81,6 +82,7 @@ suite("load") {
file
"""${getS3Url()}/regression/tpch/sf1/${tableName}.csv.split01.gz"""
time 10000 // limit inflight 10s
+ retryIfHttpError true
// stream load action will check result, include Success status,
and NumberTotalRows == NumberLoadedRows
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
