pvillard31 commented on code in PR #11570:
URL: https://github.com/apache/nifi/pull/11570#discussion_r4147109491
##########
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/registry/RegistryClientIT.java:
##########
@@ -739,4 +891,82 @@ public void
testStopVersionControlThenSetVersionControlInfo() throws NiFiClientE
assertEquals(vci.getVersionControlInformation().getVersion(),
groupAfterSetVersionInfo.getComponent().getVersionControlInformation().getVersion());
assertEquals("UP_TO_DATE",
groupAfterSetVersionInfo.getComponent().getVersionControlInformation().getState());
}
+
+ private RemovedConnectionFixture createRemovedConnectionFixture(final Path
gateFile, final boolean removeDestination,
+ final
boolean queueFlowFile) throws Exception {
+ Files.deleteIfExists(gateFile);
+ final FlowRegistryClientEntity clientEntity = registerClient();
+ final NiFiClientUtil util = getClientUtil();
+ final ProcessGroupEntity group = util.createProcessGroup("Removed
Connection Drain", "root");
+ final ProcessorEntity generate =
util.createProcessor("GenerateFlowFile", group.getId());
+ util.updateProcessorProperties(generate, Map.of("Max FlowFiles", "1",
"State Scope", "CLUSTER"));
+ if (getNumberOfNodes() > 1) {
+ util.updateProcessorExecutionNode(generate, ExecutionNode.PRIMARY);
+ }
+
+ final ProcessorEntity gated = util.createProcessor("GatedPassThrough",
group.getId());
Review Comment:
Agreed. The fixture now uses the existing TerminateFlowFile processor with
its Gate File property; I removed GatedPassThrough and its service
registration. The affected standalone and clustered scenarios pass.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
