Repository: nifi Updated Branches: refs/heads/master 7f4cfd51e -> 902b6e205
NIFI-4131 - GFT warning message when badly setting relationships Signed-off-by: Matt Burgess <[email protected]> This closes #1954 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/902b6e20 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/902b6e20 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/902b6e20 Branch: refs/heads/master Commit: 902b6e205db086aaa0f2f3a2faea66806d756e4b Parents: 7f4cfd5 Author: Pierre Villard <[email protected]> Authored: Tue Jun 27 16:27:02 2017 +0200 Committer: Matt Burgess <[email protected]> Committed: Fri Jun 30 15:12:10 2017 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/GenerateTableFetch.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/902b6e20/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java ---------------------------------------------------------------------- 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 a192d83..55fc06c 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
