This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new b2d688b5f6 Fix consuming segments cleanup on server startup (#14174)
b2d688b5f6 is described below
commit b2d688b5f60f3ed8ff2df94743a5c659a0c5c428
Author: Laxman Ch <[email protected]>
AuthorDate: Mon Oct 7 17:16:21 2024 +0530
Fix consuming segments cleanup on server startup (#14174)
Co-authored-by: Laxman Ch <[email protected]>
---
.../pinot/core/data/manager/realtime/RealtimeTableDataManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
index afc1e44529..297254529d 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
@@ -174,7 +174,7 @@ public class RealtimeTableDataManager extends
BaseTableDataManager {
Preconditions.checkState(segmentFiles != null, "Failed to list segment
files from consumer dir: %s for table: %s",
consumerDirPath, _tableNameWithType);
for (File file : segmentFiles) {
- if (file.delete()) {
+ if (FileUtils.deleteQuietly(file)) {
_logger.info("Deleted old file {}", file.getAbsolutePath());
} else {
_logger.error("Cannot delete file {}", file.getAbsolutePath());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
