[fix] fix string format for exception in RocksdbKVStore (#4448)

apache · Jun 28, 2024 · e96cf7e · e96cf7e
1 parent d1cf1db
commit e96cf7e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVStore.java b/stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVStore.java
@@ -41,6 +41,7 @@
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.List;
@@ -390,8 +391,8 @@ protected Pair<RocksDB, List<ColumnFamilyHandle>> openRocksdb(
                     byte[] other = haveTtl ? DATA_CF : DATA_TTL_CF;
                     List<byte[]> cfNames = RocksDB.listColumnFamilies(opts, dbDir.getAbsolutePath());
                     if (!cfNames.contains(wanted) && cfNames.contains(other)) {
-                        throw new StateStoreException(String.format("{}: expected {} column family, found {}",
-                                dbDir.getAbsolutePath(), wanted, other));
+                        throw new StateStoreException(String.format("%s: expected %s column family, found %s",
+                                dbDir.getAbsolutePath(), Arrays.toString(wanted), Arrays.toString(other)));
                     }
                 }
             }