This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new f0d292282c4 NIFI-16092 Imroved unstable
TestStandardRecordProcessorBlocker.TimeoutBlock.testBlockAndUnblock (#11408)
f0d292282c4 is described below
commit f0d292282c47a37715ac3cd5c9ed72818eed30ac
Author: Pierre Villard <[email protected]>
AuthorDate: Wed Jul 8 21:37:21 2026 +0200
NIFI-16092 Imroved unstable
TestStandardRecordProcessorBlocker.TimeoutBlock.testBlockAndUnblock (#11408)
Signed-off-by: David Handermann <[email protected]>
---
.../stream/pause/TestStandardRecordProcessorBlocker.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/kinesis/stream/pause/TestStandardRecordProcessorBlocker.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/kinesis/stream/pause/TestStandardRecordProcessorBlocker.java
index 66a9671f107..592aecacf6f 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/kinesis/stream/pause/TestStandardRecordProcessorBlocker.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/kinesis/stream/pause/TestStandardRecordProcessorBlocker.java
@@ -43,6 +43,7 @@ public class TestStandardRecordProcessorBlocker {
blockerInspector.awaitBlockAwaited();
assertTrue(thread.isAlive());
+ blockerInspector.awaitThreadParked(thread);
recordProcessorBlocker.unblock();
blockerInspector.awaitBlockExited();
}
@@ -96,6 +97,7 @@ public class TestStandardRecordProcessorBlocker {
blockerInspector.awaitBlockAwaited();
assertTrue(thread.isAlive());
+ blockerInspector.awaitThreadParked(thread);
recordProcessorBlocker.unblock();
blockerInspector.awaitBlockExited();
}
@@ -163,8 +165,8 @@ public class TestStandardRecordProcessorBlocker {
private static class TestThreadInspector {
private static final Duration BUSY_WAIT_MAX_DURATION =
Duration.ofSeconds(5);
- private boolean blockAwaited = false;
- private boolean blockExited = false;
+ private volatile boolean blockAwaited = false;
+ private volatile boolean blockExited = false;
public void onBlockAwaited() {
blockAwaited = true;
@@ -182,6 +184,10 @@ public class TestStandardRecordProcessorBlocker {
busyWait(() -> !blockExited);
}
+ public void awaitThreadParked(final Thread thread) {
+ busyWait(() -> thread.getState() != Thread.State.WAITING);
+ }
+
private void busyWait(final Supplier<Boolean> condition) {
final long maxWait = System.currentTimeMillis() +
BUSY_WAIT_MAX_DURATION.toMillis();
do {
