From 01d13e26dbb9a5721d225f6c356fcadc5d8db4a4 Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Fri, 9 Jun 2017 10:07:25 -0400 Subject: [PATCH] NIFI-4047: Addressed issue with inconsistent Lexical policy between used cached schemas and non-cached schemas --- .../java/org/apache/nifi/processors/standard/QueryRecord.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 5551ed11c4f3..8a9a7714e6c1 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 @@ protected QueryResult query(final ProcessSession session, final FlowFile flowFil 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;