diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java index 4c8c0be4e9..b9567a8711 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java +++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java @@ -1573,6 +1573,14 @@ public final class StandardProcessGroup implements ProcessGroup { List connections = findAllConnections(this); DropFlowFileRequest aggregateDropFlowFileStatus = new DropFlowFileRequest(dropRequestId); + + if (connections.isEmpty()) { + aggregateDropFlowFileStatus.setState(DropFlowFileState.COMPLETE); + aggregateDropFlowFileStatus.setCurrentSize(new QueueSize(0, 0L)); + aggregateDropFlowFileStatus.setOriginalSize(new QueueSize(0, 0L)); + return aggregateDropFlowFileStatus; + } + aggregateDropFlowFileStatus.setState(null); AtomicBoolean processedAtLeastOne = new AtomicBoolean(false);