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);