This is an automated email from the ASF dual-hosted git repository. jenniferdai pushed a commit to branch del in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 289ebde68f2037e8260dd09a33d8205484b1c47a Author: Jennifer Dai <[email protected]> AuthorDate: Mon Nov 19 13:19:16 2018 -0800 Fixing retention --- .../pinot/controller/helix/core/SegmentDeletionManager.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/SegmentDeletionManager.java b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/SegmentDeletionManager.java index 51e305f..0f438e3 100644 --- a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/SegmentDeletionManager.java +++ b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/SegmentDeletionManager.java @@ -203,13 +203,6 @@ public class SegmentDeletionManager { */ public void removeAgedDeletedSegments(int retentionInDays) { if (_dataDir != null) { - File deletedDir = new File(_dataDir, DELETED_SEGMENTS); - // Check that the directory for deleted segments exists - if (!deletedDir.isDirectory()) { - LOGGER.warn("Deleted segment directory {} does not exist or it is not directory.", deletedDir.getAbsolutePath()); - return; - } - URI dataDirURI = ControllerConf.getUriFromPath(_dataDir); URI deletedDirURI = ControllerConf.getUriFromPath(StringUtil.join(File.separator, _dataDir, DELETED_SEGMENTS)); PinotFS pinotFS = PinotFSFactory.create(dataDirURI.getScheme()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
