Skip to content

Commit 070d52d

Browse files
authored
NIFI-15461: Fixed bug that caused system tests to fail (#48)
1 parent 860daf9 commit 070d52d

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/main/java/org/apache/nifi/components/connector/AbstractConnector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ public CompletableFuture<Void> drainFlowFiles(final FlowContext flowContext) {
204204
return null;
205205
});
206206

207-
startNonSourceFuture.thenRun(() -> {
207+
startNonSourceFuture.thenRunAsync(() -> {
208208
try {
209209
ensureDrainageUnblocked();
210210
} catch (final Exception e) {

0 commit comments

Comments
 (0)