Merge pull request #216 from DSL-UMD/distributed

[ENH] Sync delete
umd-dslam · Oct 1, 2019 · c03a4f2 · c03a4f2
2 parents 5dd7505 + 34bee15
commit c03a4f2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...roject/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java b/...roject/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
@@ -3085,6 +3085,10 @@ boolean delete(String src, boolean recursive, boolean logRetryCache)
       removeBlocks(toRemovedBlocks); // Incremental deletion of blocks
     }
     logAuditEvent(true, operationName, src);
+    String syncStr = System.getenv("SYNC_COMMAND_LOGGING");
+    if (syncStr != null && Boolean.parseBoolean(syncStr) == true) {
+      INodeKeyedObjects.syncUpdateDB();
+    }
     return ret;
   }