You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by je...@apache.org on 2018/11/19 22:53:33 UTC
[incubator-pinot] branch del created (now 289ebde)
This is an automated email from the ASF dual-hosted git repository.
jenniferdai pushed a change to branch del
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 289ebde Fixing retention
This branch includes the following new commits:
new 289ebde Fixing retention
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: Fixing retention
Posted by je...@apache.org.
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 <jd...@linkedin.com>
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: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org