This is an automated email from the ASF dual-hosted git repository.

joewitt pushed a commit to branch support/nifi-1.16
in repository https://gitbox.apache.org/repos/asf/nifi.git

commit 358f121276c3b33ac59671e7a3f9faf54e9101ad
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Thu May 26 17:11:51 2022 -0400

    NIFI-10063: Wait for processor to become valid before attempting to start it
    
    This closes #6083
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../test/java/org/apache/nifi/tests/system/rpg/RemoteProcessGroupIT.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/rpg/RemoteProcessGroupIT.java
 
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/rpg/RemoteProcessGroupIT.java
index b25f8d1144..d58e15aea8 100644
--- 
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/rpg/RemoteProcessGroupIT.java
+++ 
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/rpg/RemoteProcessGroupIT.java
@@ -101,6 +101,7 @@ public class RemoteProcessGroupIT extends NiFiSystemIT {
         final ConnectionEntity portToCount = 
getClientUtil().createConnection(util.createConnectableDTO(port), 
util.createConnectableDTO(count), "");
 
         getNifiClient().getInputPortClient().startInputPort(port);
+        getClientUtil().waitForValidProcessor(generateFlowFile.getId());
         getNifiClient().getProcessorClient().startProcessor(generateFlowFile);
         getNifiClient().getRemoteProcessGroupClient().startTransmitting(rpg);
 

Reply via email to