nit

apache · Jan 9, 2025 · 922f6e2 · 922f6e2
1 parent 6ab195b
commit 922f6e2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java b/...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.DONE) {
+        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);