diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java index 03e3c068e42..1ae320531cf 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java @@ -655,7 +655,7 @@ public void writeComplete(int rc, long ledger, long entry, BookieId addr, Object ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor( new DefaultThreadFactory("BookKeeperClientScheduler")); BookieClientImpl bc = new BookieClientImpl(new ClientConfiguration(), eventLoopGroup, - null, executor, scheduler, NullStatsLogger.INSTANCE, b -> BookieSocketAddress.class.cast(b)); + null, executor, scheduler, NullStatsLogger.INSTANCE, BookieSocketAddress.LEGACY_BOOKIEID_RESOLVER); BookieId addr = new BookieSocketAddress(args[0], Integer.parseInt(args[1])).toBookieId(); for (int i = 0; i < 100000; i++) {