(nifi) branch main updated: NIFI-15757 Fixed Flaky test TestListenSyslog.testRunUdpInvalid with multiple iterations (#11054)

[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 82752a7f158 NIFI-15757 Fixed Flaky test 
TestListenSyslog.testRunUdpInvalid with multiple iterations (#11054)
82752a7f158 is described below

commit 82752a7f158653697138f707c7769c5b72cd5965
Author: Pierre Villard <pierre.villard...@gmail.com>
AuthorDate: Fri Mar 27 03:09:23 2026 +0100

    NIFI-15757 Fixed Flaky test TestListenSyslog.testRunUdpInvalid with 
multiple iterations (#11054)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../java/org/apache/nifi/processors/standard/TestListenSyslog.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java
 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java
index 9e55cf74a8a..d38e4276c17 100644
--- 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java
+++ 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java
@@ -56,6 +56,7 @@ public class TestListenSyslog {
     private static final String VALID_MESSAGE = String.format("<%s>%s %s %s", 
PRIORITY, TIMESTAMP, HOST, BODY);
     private static final String MIME_TYPE = "text/plain";
 
+    private static final int POLL_ITERATIONS = 10;
     private static final boolean STOP_ON_FINISH_DISABLED = false;
     private static final boolean STOP_ON_FINISH_ENABLED = true;
     private static final boolean INITIALIZE_DISABLED = false;
@@ -159,7 +160,7 @@ public class TestListenSyslog {
         final int listeningPort = ((ListenSyslog) 
runner.getProcessor()).getListeningPort();
 
         sendMessages(protocol, listeningPort, LineEnding.NONE, TIMESTAMP);
-        runner.run(1, STOP_ON_FINISH_ENABLED, INITIALIZE_DISABLED);
+        runner.run(POLL_ITERATIONS, STOP_ON_FINISH_ENABLED, 
INITIALIZE_DISABLED);
 
         final List<MockFlowFile> invalidFlowFiles = 
runner.getFlowFilesForRelationship(ListenSyslog.REL_INVALID);
         assertEquals(1, invalidFlowFiles.size(), "Invalid FlowFiles not 
matched");
@@ -179,7 +180,7 @@ public class TestListenSyslog {
         final int port = ((ListenSyslog) 
runner.getProcessor()).getListeningPort();
 
         sendMessages(protocol, port, LineEnding.UNIX, VALID_MESSAGE);
-        runner.run(1, STOP_ON_FINISH_ENABLED, INITIALIZE_DISABLED);
+        runner.run(POLL_ITERATIONS, STOP_ON_FINISH_ENABLED, 
INITIALIZE_DISABLED);
 
         final List<MockFlowFile> invalidFlowFiles = 
runner.getFlowFilesForRelationship(ListenSyslog.REL_INVALID);
         assertTrue(invalidFlowFiles.isEmpty(), "Invalid FlowFiles found");