Fix tests.

apache · Mar 31, 2022 · b9f1b79 · b9f1b79
1 parent 8b13d3d
commit b9f1b79
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...rc/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionBufferClientTest.java b/...rc/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionBufferClientTest.java
@@ -164,15 +164,15 @@ public void testTransactionBufferClientTimeout() throws Exception {
         CompletableFuture<TxnID> endFuture =
                 transactionBufferHandler.endTxnOnTopic("test", 1, 1, TxnAction.ABORT, 1);
 
-        Field field = TransactionBufferHandlerImpl.class.getDeclaredField("pendingRequests");
+        Field field = TransactionBufferHandlerImpl.class.getDeclaredField("outstandingRequests");
         field.setAccessible(true);
-        ConcurrentSkipListMap<Long, Object> pendingRequests =
+        ConcurrentSkipListMap<Long, Object> outstandingRequests =
                 (ConcurrentSkipListMap<Long, Object>) field.get(transactionBufferHandler);
 
-        assertEquals(pendingRequests.size(), 1);
+        assertEquals(outstandingRequests.size(), 1);
 
         Awaitility.await().atLeast(2, TimeUnit.SECONDS).until(() -> {
-            if (pendingRequests.size() == 0) {
+            if (outstandingRequests.size() == 0) {
                 return true;
             }
             return false;