Skip to content

Commit 6c0e738

Browse files
smkniaziGautier Berthou
authored and
Gautier Berthou
committed
[HOPS-1564] Fixed bug in transaction cache
1 parent 7c4a812 commit 6c0e738

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/main/java/io/hops/metadata/ndb/dalimpl/hdfs/ReplicaUnderConstructionClusterj.java

+6
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import io.hops.metadata.hdfs.entity.ReplicaUnderConstruction;
3131
import io.hops.metadata.ndb.ClusterjConnector;
3232
import io.hops.metadata.ndb.NdbBoolean;
33+
import io.hops.metadata.ndb.mysqlserver.MySQLQueryHelper;
3334
import io.hops.metadata.ndb.wrapper.HopsPredicate;
3435
import io.hops.metadata.ndb.wrapper.HopsQuery;
3536
import io.hops.metadata.ndb.wrapper.HopsQueryBuilder;
@@ -185,6 +186,11 @@ public void removeByBlockIdAndInodeId(long blockId, long inodeId) throws
185186
query.deletePersistentAll();
186187
}
187188

189+
@Override
190+
public int countAll() throws StorageException {
191+
return MySQLQueryHelper.countAll(TABLE_NAME);
192+
}
193+
188194
private List<ReplicaUnderConstruction> convertAndRelease(HopsSession session,
189195
List<ReplicaUcDTO> replicaUc) throws StorageException {
190196
List<ReplicaUnderConstruction> replicas =

0 commit comments

Comments
 (0)