Repository: nifi Updated Branches: refs/heads/master cc741d2be -> d8dc2bb00
NIFI-4047: Addressed issue with inconsistent Lexical policy between used cached schemas and non-cached schemas This closes #1907 Signed-off-by: Joe Percivall <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d8dc2bb0 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d8dc2bb0 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d8dc2bb0 Branch: refs/heads/master Commit: d8dc2bb00b6ccfe3faa42481ae541616401b4075 Parents: cc741d2 Author: Mark Payne <[email protected]> Authored: Fri Jun 9 10:07:25 2017 -0400 Committer: Joe Percivall <[email protected]> Committed: Fri Jun 9 12:05:11 2017 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/standard/QueryRecord.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/d8dc2bb0/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java index 5551ed1..8a9a771 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java @@ -472,7 +472,7 @@ public class QueryRecord extends AbstractProcessor { final RecordReaderFactory recordParserFactory) throws SQLException { final Properties properties = new Properties(); - properties.put(CalciteConnectionProperty.LEX.camelName(), Lex.JAVA.name()); + properties.put(CalciteConnectionProperty.LEX.camelName(), Lex.MYSQL_ANSI.name()); Connection connection = null; ResultSet resultSet = null;
