Repository: nifi Updated Branches: refs/heads/master dae25accb -> 6bdcd3913
nifi-1247 Correction for check of UnmatchedFieldBehaviour in generateUpdate to match generateInsert correct functionality Signed-off-by: Mark Payne <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/6bdcd391 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/6bdcd391 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/6bdcd391 Branch: refs/heads/master Commit: 6bdcd3913f8ec39633cf4f1dd8c74ad9d59447c3 Parents: dae25ac Author: Daniel Cave <[email protected]> Authored: Thu Dec 3 18:55:46 2015 +0000 Committer: Mark Payne <[email protected]> Committed: Thu Dec 3 14:12:23 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/6bdcd391/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java index 902af51..4125eeb 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ConvertJSONToSQL.java @@ -471,7 +471,7 @@ public class ConvertJSONToSQL extends AbstractProcessor { final ColumnDescription desc = schema.getColumns().get(normalizedColName); if (desc == null) { - if (ignoreUnmappedFields) { + if (!ignoreUnmappedFields) { throw new ProcessException("Cannot map JSON field '" + fieldName + "' to any column in the database"); } else { continue;
