(doris) branch master updated: [fix](test) Fix flaky assertion in test_streaming_insert_job_fetch_meta_error (#62499)

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

JNSimba 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 d15d71d21a2 [fix](test) Fix flaky assertion in test_streaming_insert_job_fetch_meta_error (#62499)
d15d71d21a2 is described below

commit d15d71d21a214def57eb4ddfe2dc193762982395
Author: wudi <wu...@selectdb.com>
AuthorDate: Mon Apr 20 10:44:39 2026 +0800

    [fix](test) Fix flaky assertion in test_streaming_insert_job_fetch_meta_error (#62499)
    
    ### What problem does this PR solve?
    
    PR #62023 refactored the filesystem SPI, which changed the error
    propagation path in `S3SourceOffsetProvider.fetchRemoteMeta()`.
    
    Previously (#61284), the debug point created a `GlobListResult` with an
    error status, and the subsequent status check threw an exception with
    message `"Failed to list S3 files: ..."`. After the refactoring in
    #62023, the debug point was changed to directly throw an `IOException`,
    which is caught by `StreamingInsertJob.fetchMeta()` and wrapped as
    `"Failed to fetch meta, ..."`. However, the regression test assertion
    was not updated accordingly, causing the test to fail intermittently.
    
    Co-authored-by: Claude Opus 4.6 (1M context) <no...@anthropic.com>
---
 .../streaming_job/test_streaming_insert_job_fetch_meta_error.groovy     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/regression-test/suites/job_p0/streaming_job/test_streaming_insert_job_fetch_meta_error.groovy b/regression-test/suites/job_p0/streaming_job/test_streaming_insert_job_fetch_meta_error.groovy
index fab3bf1397e..4be3d3ac8cb 100644
--- a/regression-test/suites/job_p0/streaming_job/test_streaming_insert_job_fetch_meta_error.groovy
+++ b/regression-test/suites/job_p0/streaming_job/test_streaming_insert_job_fetch_meta_error.groovy
@@ -80,7 +80,7 @@ suite("test_streaming_insert_job_fetch_meta_error", "nonConcurrent") {
 
         def jobStatus = sql """select Status, ErrorMsg from jobs("type"="insert") where Name='${jobName}'"""
         assert jobStatus.get(0).get(0) == "PAUSED"
-        assert jobStatus.get(0).get(1).contains("Failed to list S3 files")
+        assert jobStatus.get(0).get(1).contains("simulated S3 auth error")
 
         sql """
             DROP JOB IF EXISTS where jobname = '${jobName}'


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org