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 <[email protected]> Authored: Mon Oct 27 12:35:11 2014 -0700 Committer: Chris Riccomini <[email protected]> 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)
