diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBStoragePartition.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBStoragePartition.java
index 4b200bd9fd..09c4d92f98 100644
--- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBStoragePartition.java
+++ b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/store/rocksdb/RocksDBStoragePartition.java
@@ -750,7 +750,7 @@ public synchronized Map<String, String> sync() {
           // Since Venice RocksDB database disables WAL, flush will be triggered for every 'sync' to avoid data loss
           // during
           // crash recovery
-          rocksDB.flush(WAIT_FOR_FLUSH_OPTIONS);
+          rocksDB.flush(WAIT_FOR_FLUSH_OPTIONS, columnFamilyHandleList);
         } catch (RocksDBException e) {
           checkAndThrowMemoryLimitException(e);
           throw new VeniceException(