9aman commented on code in PR #15142: URL: https://github.com/apache/pinot/pull/15142#discussion_r1984776827
########## pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/retention/RetentionManager.java: ########## @@ -124,8 +138,19 @@ private void manageRetentionForTable(TableConfig tableConfig) { } private void manageRetentionForOfflineTable(String offlineTableName, RetentionStrategy retentionStrategy) { + List<SegmentZKMetadata> segmentZKMetadataList = _pinotHelixResourceManager.getSegmentsZKMetadata(offlineTableName); Review Comment: If the deletion fails in the middle then the segment will be in ZK but not in IS. Moreover, as per Xiang we have seen cases where the SegmentRefreshTask etc push segment in Deepstore and ZK but fail to update the IS. In that case as well we have such segments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org