[fix][test]flaky-test:ManagedLedgerInterceptorImplTest.testManagedLedgerPayloadInputProcessorFailure (#24170)

3pacccccc · web-flow · commit acc933626790 · 2025-04-11T08:24:42.000+03:00
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImplTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImplTest.java
@@ -470,8 +470,8 @@ public void release(ByteBuf processedPayload) {
         var addEntryCallback = new AsyncCallbacks.AddEntryCallback() {
             @Override
             public void addComplete(Position position, ByteBuf entryData, Object ctx) {
-                countDownLatch.countDown();
                 successCount.incrementAndGet();
+                countDownLatch.countDown();
             }
 
             @Override

Original file line number	Diff line number	Diff line change
`@@ -470,8 +470,8 @@ public void release(ByteBuf processedPayload) {`
`470`	`470`	`var addEntryCallback = new AsyncCallbacks.AddEntryCallback() {`
`471`	`471`	`@Override`
`472`	`472`	`public void addComplete(Position position, ByteBuf entryData, Object ctx) {`
`473`		`- countDownLatch.countDown();`
`474`	`473`	`successCount.incrementAndGet();`
	`474`	`+ countDownLatch.countDown();`
`475`	`475`	`}`
`476`	`476`
`477`	`477`	`@Override`