diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java index e272cb8692c0..d2a2812bcd59 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java @@ -1032,10 +1032,13 @@ private boolean isKeyPresentInTableCache(String keyPrefix, */ private boolean isKeyPresentInTable(String keyPrefix, Table table) - throws IOException { + throws IOException { try (TableIterator> - keyIter = table.iterator()) { - KeyValue kv = keyIter.seek(keyPrefix); + keyIter = table.iterator(keyPrefix)) { + KeyValue kv = null; + if (keyIter.hasNext()) { + kv = keyIter.next(); + } // Iterate through all the entries in the table which start with // the current bucket's prefix.