This is an automated email from the ASF dual-hosted git repository.
hemant 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 07f31082ee HDDS-9778. Disable rocksDB cache for snapshot (#5676)
07f31082ee is described below
commit 07f31082eefcf38417cd60322511bd94d493a5b0
Author: Swaminathan Balachandran <[email protected]>
AuthorDate: Wed Nov 29 12:40:00 2023 +0530
HDDS-9778. Disable rocksDB cache for snapshot (#5676)
---
.../org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java | 11 +++++------
.../ozone/recon/recovery/ReconOmMetadataManagerImpl.java | 3 ++-
2 files changed, 7 insertions(+), 7 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 6685e9a2ec..42179294e5 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
@@ -380,7 +380,7 @@ public class OmMetadataManagerImpl implements
OMMetadataManager,
omEpoch = 0;
setStore(loadDB(conf, dir, name, true,
java.util.Optional.of(Boolean.TRUE), Optional.empty()));
- initializeOmTables(false);
+ initializeOmTables(CacheType.PARTIAL_CACHE, false);
}
@@ -413,7 +413,7 @@ public class OmMetadataManagerImpl implements
OMMetadataManager,
setStore(loadDB(conf, metaDir, dbName, false,
java.util.Optional.of(Boolean.TRUE),
Optional.of(maxOpenFiles), false, false));
- initializeOmTables(false);
+ initializeOmTables(CacheType.PARTIAL_CACHE, false);
} catch (IOException e) {
stop();
throw e;
@@ -557,7 +557,7 @@ public class OmMetadataManagerImpl implements
OMMetadataManager,
this.store = loadDB(configuration, metaDir);
- initializeOmTables(true);
+ initializeOmTables(CacheType.FULL_CACHE, true);
}
snapshotChainManager = new SnapshotChainManager(this);
@@ -652,15 +652,14 @@ public class OmMetadataManagerImpl implements
OMMetadataManager,
*
* @throws IOException
*/
- protected void initializeOmTables(boolean addCacheMetrics)
+ protected void initializeOmTables(CacheType cacheType,
+ boolean addCacheMetrics)
throws IOException {
userTable =
this.store.getTable(USER_TABLE, String.class,
PersistedUserVolumeInfo.class);
checkTableStatus(userTable, USER_TABLE, addCacheMetrics);
- CacheType cacheType = CacheType.FULL_CACHE;
-
volumeTable =
this.store.getTable(VOLUME_TABLE, String.class, OmVolumeArgs.class,
cacheType);
diff --git
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/recovery/ReconOmMetadataManagerImpl.java
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/recovery/ReconOmMetadataManagerImpl.java
index 856f7cb083..ad0526363d 100644
---
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/recovery/ReconOmMetadataManagerImpl.java
+++
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/recovery/ReconOmMetadataManagerImpl.java
@@ -38,6 +38,7 @@ import org.apache.hadoop.hdds.conf.OzoneConfiguration;
import org.apache.hadoop.hdds.utils.db.RDBStore;
import org.apache.hadoop.hdds.utils.db.Table;
import org.apache.hadoop.hdds.utils.db.TableIterator;
+import org.apache.hadoop.hdds.utils.db.cache.TableCache;
import org.apache.hadoop.ozone.om.OmMetadataManagerImpl;
import org.apache.hadoop.hdds.utils.db.DBStore;
import org.apache.hadoop.hdds.utils.db.DBStoreBuilder;
@@ -109,7 +110,7 @@ public class ReconOmMetadataManagerImpl extends
OmMetadataManagerImpl
LOG.error("Unable to initialize Recon OM DB snapshot store.", ioEx);
}
if (getStore() != null) {
- initializeOmTables(true);
+ initializeOmTables(TableCache.CacheType.FULL_CACHE, true);
omTablesInitialized = true;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
