NIFI-10063: Wait for processor to become valid before attempting to start it

This closes #6083

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Mark Payne 2022-05-26 17:11:51 -04:00 committed by exceptionfactory
parent 9878df9f5a
commit 005fbe3c50
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
1 changed files with 1 additions and 0 deletions

View File

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