diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java index a192d83fc1..55fc06c9de 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java @@ -154,6 +154,9 @@ public class GenerateTableFetch extends AbstractDatabaseFetchProcessor { if (!isDynamicTableName && !isDynamicMaxValues) { super.setup(context); } + if(context.hasIncomingConnection() && !context.hasNonLoopConnection()) { + getLogger().error("The failure relationship can be used only if there is another incoming connection to this processor."); + } } @Override