From 6ab195b2b83b909961784724bb489fa95bb0e2b2 Mon Sep 17 00:00:00 2001
From: Harnoor7 <harnoor@startree.ai>
Date: Fri, 10 Jan 2025 02:07:28 +0530
Subject: [PATCH] addresses PR comment

---
 .../core/data/manager/realtime/RealtimeSegmentDataManager.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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