This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 6f6ec58074 HDDS-10154. isKeyPresentInTable should use iterator
constructor with prefix (#6022)
6f6ec58074 is described below
commit 6f6ec580743208ba4c09e9b55b94f68cfefd2d5d
Author: Ritesh H Shukla <[email protected]>
AuthorDate: Fri Jan 19 13:08:27 2024 -0800
HDDS-10154. isKeyPresentInTable should use iterator constructor with prefix
(#6022)
---
.../java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
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 0f29857723..1f8c3ba3cd 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 @@ public class OmMetadataManagerImpl implements
OMMetadataManager,
*/
private <T> boolean isKeyPresentInTable(String keyPrefix,
Table<String, T> table)
- throws IOException {
+ throws IOException {
try (TableIterator<String, ? extends KeyValue<String, T>>
- keyIter = table.iterator()) {
- KeyValue<String, T> kv = keyIter.seek(keyPrefix);
+ keyIter = table.iterator(keyPrefix)) {
+ KeyValue<String, T> kv = null;
+ if (keyIter.hasNext()) {
+ kv = keyIter.next();
+ }
// Iterate through all the entries in the table which start with
// the current bucket's prefix.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
