From b1f4d00129c465ad8f427e32e2cd53a91aec5056 Mon Sep 17 00:00:00 2001 From: Salman Niazi Date: Fri, 12 Feb 2021 10:32:32 +0100 Subject: [PATCH] [HOPSWORKS-CLOUD-1540] Fixing cleaning up subtree operations --- .../hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java b/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java index 448a8d1f..5a438c4d 100644 --- a/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java +++ b/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java @@ -30,6 +30,12 @@ public interface OngoingSubTreeOpsDataAccess extends EntityDataAccess { Collection allOpsToRecoverAsync() throws StorageException; + Collection allDeadOperations(long[] aliveNNIDs, long time) throws StorageException; + + Collection allSlowActiveOperations(long[] aliveNNIDs, long time) throws StorageException; + + long getLockTime(long inodeID) throws StorageException; + //only for testing Collection allOps() throws StorageException;