diff --git a/fe/src/main/java/org/apache/doris/common/proc/StatisticProcDir.java b/fe/src/main/java/org/apache/doris/common/proc/StatisticProcDir.java
index 05f209f5d15ffa..d36a9232207a57 100644
--- a/fe/src/main/java/org/apache/doris/common/proc/StatisticProcDir.java
+++ b/fe/src/main/java/org/apache/doris/common/proc/StatisticProcDir.java
@@ -127,7 +127,8 @@ public ProcResult fetchResult() throws AnalysisException {
                                         partition.getVisibleVersion(), partition.getVisibleVersionHash(),
                                         replicationNum);
 
-                                if (res.first != TabletStatus.HEALTHY) {
+                                // here we treat REDUNDANT as HEALTHY, for user friendly.
+                                if (res.first != TabletStatus.HEALTHY && res.first != TabletStatus.REDUNDANT) {
                                     unhealthyTabletIds.put(dbId, tablet.getId());
                                 }
 
diff --git a/fe/src/main/java/org/apache/doris/load/Load.java b/fe/src/main/java/org/apache/doris/load/Load.java
index 9081d6cf0b34b8..4655d9a5890e51 100644
--- a/fe/src/main/java/org/apache/doris/load/Load.java
+++ b/fe/src/main/java/org/apache/doris/load/Load.java
@@ -3008,12 +3008,12 @@ private void checkDelete(OlapTable table, Partition partition, List<Predicate> c
         }
     }
 
-    private void checkAndAddRunningSyncDeleteJob(long partitionId, String partitionName) throws DdlException {
+    private boolean checkAndAddRunningSyncDeleteJob(long partitionId, String partitionName) throws DdlException {
         // check if there are synchronized delete job under going
         writeLock();
         try {
             checkHasRunningSyncDeleteJob(partitionId, partitionName);
-            partitionUnderDelete.add(partitionId);
+            return partitionUnderDelete.add(partitionId);
         } finally {
             writeUnlock();
         }
@@ -3073,6 +3073,7 @@ public void delete(DeleteStmt stmt) throws DdlException {
         long tableId = -1;
         long partitionId = -1;
         LoadJob loadDeleteJob = null;
+        boolean addRunningPartition = false;
         db.readLock();
         try {
             Table table = db.getTable(tableName);
@@ -3110,7 +3111,7 @@ public void delete(DeleteStmt stmt) throws DdlException {
             // pre check
             checkDeleteV2(olapTable, partition, conditions,
                           deleteConditions, true);
-            checkAndAddRunningSyncDeleteJob(partitionId, partitionName);
+            addRunningPartition = checkAndAddRunningSyncDeleteJob(partitionId, partitionName);
             // do not use transaction id generator, or the id maybe duplicated
             long jobId = Catalog.getInstance().getNextId();
             String jobLabel = "delete_" + UUID.randomUUID();
@@ -3137,11 +3138,20 @@ public void delete(DeleteStmt stmt) throws DdlException {
             // the delete job will be persist in editLog
             addLoadJob(loadDeleteJob, db);
         } catch (Throwable t) {
-            LOG.debug("error occurred during prepare delete", t);
+            LOG.warn("error occurred during prepare delete", t);
             throw new DdlException(t.getMessage(), t);
         } finally {
+            if (addRunningPartition) {
+                writeLock();
+                try {
+                    partitionUnderDelete.remove(partitionId);
+                } finally {
+                    writeUnlock();
+                }
+            }
             db.readUnlock();
         }
+
         try {
             // TODO  wait loadDeleteJob to finished, using while true? or condition wait
             long startDeleteTime = System.currentTimeMillis();