[accumulo] branch main updated: Add exists check to TableDiskUsage. Fixes #2428 (#2430)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmiller pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/main by this push:
     new 0e4baf3  Add exists check to TableDiskUsage. Fixes #2428 (#2430)
0e4baf3 is described below

commit 0e4baf318d1108712b1282605e358a799c34966e
Author: Mike Miller <mm...@apache.org>
AuthorDate: Tue Jan 25 09:16:06 2022 -0500

    Add exists check to TableDiskUsage. Fixes #2428 (#2430)
---
 .../main/java/org/apache/accumulo/server/util/TableDiskUsage.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/server/base/src/main/java/org/apache/accumulo/server/util/TableDiskUsage.java b/server/base/src/main/java/org/apache/accumulo/server/util/TableDiskUsage.java
index 8b281f6..2a37330 100644
--- a/server/base/src/main/java/org/apache/accumulo/server/util/TableDiskUsage.java
+++ b/server/base/src/main/java/org/apache/accumulo/server/util/TableDiskUsage.java
@@ -215,6 +215,11 @@ public class TableDiskUsage {
       for (String tableDir : nameSpacesReferenced) {
         // Find each file and add its size
         Path path = new Path(tableDir + "/" + tableId);
+        if (!fs.exists(path)) {
+          log.debug("Table ID directory {} does not exist.", path);
+          continue;
+        }
+        log.info("Get all files recursively in {}", path);
         RemoteIterator<LocatedFileStatus> ri = fs.listFiles(path, true);
         while (ri.hasNext()) {
           FileStatus status = ri.next();