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;
             }