diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/BookieBackpressureForV2Test.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/BookieBackpressureForV2Test.java index 775844d05e6..5dfd7d60528 100644 --- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/BookieBackpressureForV2Test.java +++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/proto/BookieBackpressureForV2Test.java @@ -31,6 +31,6 @@ public void setUp() throws Exception { super.setUp(); baseClientConf.setUseV2WireProtocol(true); // the backpressure will bloc the read response, disable it to let it use backpressure mechanism - confByIndex(0).setReadWorkerThreadsThrottlingEnabled(false); + bsConfs.get(0).setReadWorkerThreadsThrottlingEnabled(false); } }