From c39be48bc77731ab041db4ca32cffd49d9b8fc1c Mon Sep 17 00:00:00 2001 From: wudi Date: Wed, 14 Jan 2026 15:29:19 +0800 Subject: [PATCH 1/3] fix autoresume clear error --- .../java/org/apache/doris/job/common/FailureReason.java | 7 ++++++- .../insert/streaming/StreamingJobSchedulerTask.java | 1 - 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/common/FailureReason.java b/fe/fe-core/src/main/java/org/apache/doris/job/common/FailureReason.java index c554f750b552e3..7f2ba752812e88 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/common/FailureReason.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/common/FailureReason.java @@ -41,13 +41,18 @@ public FailureReason(InternalErrorCode errCode, String msg) { public FailureReason(String msg) { this.msg = msg; - if (StringUtils.isNotEmpty(msg) && msg.contains("Insert has filtered data in strict mode")) { + if (StringUtils.isNotEmpty(msg) && isTooManyFailureRowsErr(msg)) { this.code = InternalErrorCode.TOO_MANY_FAILURE_ROWS_ERR; } else { this.code = InternalErrorCode.INTERNAL_ERR; } } + private static boolean isTooManyFailureRowsErr(String msg) { + return msg.contains("Insert has filtered data in strict mode") + || msg.contains("too many filtered rows"); + } + public InternalErrorCode getCode() { return code; } diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java index 2d26db535fd172..942a25812dbb37 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java @@ -94,7 +94,6 @@ private void autoResumeHandler() throws JobException { if (autoResumeCount < Long.MAX_VALUE) { streamingInsertJob.setAutoResumeCount(autoResumeCount + 1); } - streamingInsertJob.resetFailureInfo(null); streamingInsertJob.updateJobStatus(JobStatus.PENDING); return; } From 20f139e1f78e60854498cf18f22186a55f060fd7 Mon Sep 17 00:00:00 2001 From: wudi Date: Wed, 14 Jan 2026 16:28:38 +0800 Subject: [PATCH 2/3] fix --- .../extensions/insert/streaming/StreamingJobSchedulerTask.java | 1 + 1 file changed, 1 insertion(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java index 942a25812dbb37..2d26db535fd172 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java @@ -94,6 +94,7 @@ private void autoResumeHandler() throws JobException { if (autoResumeCount < Long.MAX_VALUE) { streamingInsertJob.setAutoResumeCount(autoResumeCount + 1); } + streamingInsertJob.resetFailureInfo(null); streamingInsertJob.updateJobStatus(JobStatus.PENDING); return; } From ca10b713f0b0fbd80b924ec842ebab2b8860094e Mon Sep 17 00:00:00 2001 From: wudi Date: Wed, 14 Jan 2026 16:41:53 +0800 Subject: [PATCH 3/3] fix --- .../extensions/insert/streaming/StreamingJobSchedulerTask.java | 1 - 1 file changed, 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java index 2d26db535fd172..942a25812dbb37 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java @@ -94,7 +94,6 @@ private void autoResumeHandler() throws JobException { if (autoResumeCount < Long.MAX_VALUE) { streamingInsertJob.setAutoResumeCount(autoResumeCount + 1); } - streamingInsertJob.resetFailureInfo(null); streamingInsertJob.updateJobStatus(JobStatus.PENDING); return; }