(nifi) branch main updated: NIFI-14747 Set Test Kinesis Record Processor Timeout to 5 seconds (#10088)

[exceptionfactory]

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 b77991b616 NIFI-14747 Set Test Kinesis Record Processor Timeout to 5 
seconds (#10088)
b77991b616 is described below

commit b77991b6162d873b6e98e913854c9d1fc17aa1a6
Author: Dariusz Seweryn <dariusz.sewe...@gmail.com>
AuthorDate: Tue Jul 15 04:53:05 2025 +0200

    NIFI-14747 Set Test Kinesis Record Processor Timeout to 5 seconds (#10088)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../kinesis/stream/pause/TestStandardRecordProcessorBlocker.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

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 6b96686e42..66a9671f10 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
@@ -19,6 +19,7 @@ package org.apache.nifi.processors.aws.kinesis.stream.pause;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 
+import java.time.Duration;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Supplier;
 
@@ -161,6 +162,7 @@ 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;
 
@@ -181,11 +183,16 @@ public class TestStandardRecordProcessorBlocker {
         }
 
         private void busyWait(final Supplier<Boolean> condition) {
-            final long maxWait = System.currentTimeMillis() + 1000;
+            final long maxWait = System.currentTimeMillis() + 
BUSY_WAIT_MAX_DURATION.toMillis();
             do {
                 if (System.currentTimeMillis() > maxWait) {
                     throw new RuntimeException("Timed out waiting for 
condition");
                 }
+                try {
+                    Thread.sleep(10L); // Sleep to avoid busy waiting too 
aggressively
+                } catch (final InterruptedException e) {
+                    throw new RuntimeException("Thread interrupted while 
waiting for condition", e);
+                }
             } while (condition.get());
         }
     }