wkochman opened a new pull request, #11528:
URL: https://github.com/apache/nifi/pull/11528

   ### Summary
   
   The connector mock server previously stopped a Connector with a single fixed 
10-second blocking wait (`connectorNode.stop(...).get(10, SECONDS)`). On slower 
shutdown paths (for example, a failed table still draining) this could time out 
even though the Connector node retries its stop internally and eventually 
reaches `STOPPED`, causing otherwise-passing tests to fail during teardown.
   
   This adds a timeout-aware, active-polling stop to the mock framework.
   
   ### Changes
   
   - `ConnectorTestRunner`: add a `default void stopConnector(Duration 
timeout)` overload (backward compatible for existing implementors).
   - `StandardConnectorMockServer`: initiate the async stop, then poll the 
Connector state until `STOPPED` within the given timeout instead of a single 
fixed wait (default budget 60s, 250ms poll interval). A healthy stop still 
returns immediately.
   - `StandardConnectorTestRunner`: pass the timeout through to the mock server.
   - `CreateConnectorIT`: new IT exercising the overload end-to-end against the 
real `GenerateAndLog` connector.
   
   ### Testing
   
   `CreateConnectorIT` (integration-tests profile) passes locally:
   `Tests run: 1, Failures: 0, Errors: 0, Skipped: 0` for 
`testStopConnectorWithTimeoutStopsRunningConnector`.
   


-- 
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]

Reply via email to