You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/10/27 20:35:19 UTC
git commit: SAMZA-446; remove rocksdb block size cache override config
Repository: incubator-samza
Updated Branches:
refs/heads/master e63cfd39c -> f6d341508
SAMZA-446; remove rocksdb block size cache override config
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/f6d34150
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/f6d34150
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/f6d34150
Branch: refs/heads/master
Commit: f6d341508ebc6dccc158374130a9a6ecf07422ca
Parents: e63cfd3
Author: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Authored: Mon Oct 27 12:35:11 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Mon Oct 27 12:35:11 2014 -0700
----------------------------------------------------------------------
.../scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/f6d34150/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
----------------------------------------------------------------------
diff --git a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
index 4b23c9b..eae2a5a 100644
--- a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
+++ b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
@@ -49,9 +49,6 @@ object RocksDbKeyValueStore extends Logging {
})
val blockSize = storeConfig.getInt("rocksdb.block.size.bytes", 4096)
- // We compute the cache size based on the overall container cache size,
- // however, if rocksdb.cache.size.bytes is overridden, then we use that.
- cacheSizePerContainer = storeConfig.getLong("rocksdb.cache.size.bytes", cacheSizePerContainer)
val bloomBits = storeConfig.getInt("rocksdb.bloomfilter.bits", 10)
val table_options = new BlockBasedTableConfig()
table_options.setBlockCacheSize(cacheSizePerContainer)