BUG FIX: set target file size multiplier

apache · Aug 7, 2024 · 2598619 · 2598619
1 parent f9c3241
commit 2598619
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java b/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java
@@ -180,7 +180,7 @@ private static void setCompactionOptions(Config storeConfig, Options options) {
     }
 
     if (storeConfig.containsKey(ROCKSDB_COMPACTION_TARGET_FILE_SIZE_MULTIPLIER)) {
-      options.setTargetFileSizeBase(storeConfig.getLong(ROCKSDB_COMPACTION_TARGET_FILE_SIZE_MULTIPLIER));
+      options.setTargetFileSizeMultiplier(storeConfig.getInt(ROCKSDB_COMPACTION_TARGET_FILE_SIZE_MULTIPLIER));
     }
 
     if (storeConfig.containsKey(ROCKSDB_MAX_BACKGROUND_JOBS)) {