Fix bug in KillStalePendingSegments (#14961)

apache · Sep 11, 2023 · 7871e63 · 7871e63
1 parent dec6a0a
commit 7871e63
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/server/src/main/java/org/apache/druid/server/coordinator/duty/KillStalePendingSegments.java b/server/src/main/java/org/apache/druid/server/coordinator/duty/KillStalePendingSegments.java
@@ -118,9 +118,7 @@ private DateTime getMinCreatedTimeToRetain()
     DateTime earliestActiveTaskStart = DateTimes.nowUtc();
     DateTime latestCompletedTaskStart = null;
     for (TaskStatusPlus status : statuses) {
-      if (status.getStatusCode() == null) {
-        // Unknown status
-      } else if (status.getStatusCode().isComplete()) {
+      if (status.getStatusCode() != null && status.getStatusCode().isComplete()) {
         latestCompletedTaskStart = DateTimes.laterOf(
             latestCompletedTaskStart,
             status.getCreatedTime()