pvillard31 commented on code in PR #11570:
URL: https://github.com/apache/nifi/pull/11570#discussion_r4147101019
##########
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/registry/RegistryClientIT.java:
##########
@@ -58,6 +63,153 @@ public class RegistryClientIT extends NiFiSystemIT {
public static final String FIRST_FLOW_ID = "first-flow";
+ @Test
+ public void testChangeVersionDrainsRemovedConnectionBeforeUpdate() throws
Exception {
+ final Path gateFile = Path.of(System.getProperty("java.io.tmpdir"),
"nifi-removed-connection-drain-" + System.nanoTime());
+ final RemovedConnectionFixture fixture =
createRemovedConnectionFixture(gateFile, false, true);
+ final NiFiClientUtil util = getClientUtil();
+
+ final VersionedFlowUpdateRequestEntity initiated =
util.initiateFlowVersionChange(fixture.groupId(), "2");
+ final String requestId = initiated.getRequest().getRequestId();
+ waitFor(() -> "Draining Removed
Connections".equals(getNifiClient().getVersionsClient().getUpdateRequest(requestId).getRequest().getState()));
Review Comment:
Agreed. While the gate holds the drain, the system test asserts source
STOPPED and destination RUNNING using non-replicated reads on each cluster
node. The standalone helper also avoids switching to a cluster-only port.
--
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]
