diff --git a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
index 9a7067b5300a..f600c1713102 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
@@ -1624,7 +1624,7 @@ public RealtimeSegmentDataManager(SegmentZKMetadata segmentZKMetadata, TableConf
         // reload segment metadata to get latest status
         segmentZKMetadata = _realtimeTableDataManager.fetchZKMetadata(_segmentNameStr);
 
-        if (segmentZKMetadata.getStatus() != CommonConstants.Segment.Realtime.Status.IN_PROGRESS) {
+        if (segmentZKMetadata.getStatus() != CommonConstants.Segment.Realtime.Status.DONE) {
           // segment has already been uploaded by another server.
           _segmentLogger.warn("segment: {} already exists. Skipping creation of RealtimeSegmentDataManager",
               _segmentNameStr);