Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
addresses PR comment
Browse files Browse the repository at this point in the history
noob-se7en committed Jan 9, 2025
1 parent 90444bb commit 6ab195b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
@@ -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);

0 comments on commit 6ab195b

Please sign in to comment.