Repository: nifi Updated Branches: refs/heads/master 2d58497c2 -> 71e2061b5
NIFI-2968 This closes #1377. Improved message when ExecuteSQL hits unsupported SQL types Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/71e2061b Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/71e2061b Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/71e2061b Branch: refs/heads/master Commit: 71e2061b5dbd286e45855c81473e849583ead9df Parents: 2d58497 Author: Pierre Villard <[email protected]> Authored: Fri Dec 30 15:20:00 2016 +0100 Committer: joewitt <[email protected]> Committed: Tue Feb 14 23:25:29 2017 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/util/JdbcCommon.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/71e2061b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java index 49be067..40709d0 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JdbcCommon.java @@ -347,7 +347,8 @@ public class JdbcCommon { default: - throw new IllegalArgumentException("createSchema: Unknown SQL type " + meta.getColumnType(i) + " cannot be converted to Avro type"); + throw new IllegalArgumentException("createSchema: Unknown SQL type " + meta.getColumnType(i) + " / " + meta.getColumnTypeName(i) + + " (table: " + tableName + ", column: " + columnName + ") cannot be converted to Avro type"); } }
