[nifi] branch main updated: NIFI-9663 Setting the "csv-escape" property has no effect in SelectHive3QL

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 357a866  NIFI-9663 Setting the "csv-escape" property has no effect in 
SelectHive3QL
357a866 is described below

commit 357a8667f98b054436a789a008e9c56ca07417d6
Author: Robert Kalmar <rkal...@cloudera.com>
AuthorDate: Thu Feb 10 10:05:37 2022 +0100

    NIFI-9663 Setting the "csv-escape" property has no effect in SelectHive3QL
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #5756.
---
 .../src/main/java/org/apache/nifi/processors/hive/SelectHive3QL.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/SelectHive3QL.java
 
b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/SelectHive3QL.java
index af87bd1..891000e 100644
--- 
a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/SelectHive3QL.java
+++ 
b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/SelectHive3QL.java
@@ -359,7 +359,7 @@ public class SelectHive3QL extends AbstractHive3QLProcessor 
{
         final String altHeader = 
context.getProperty(HIVEQL_CSV_ALT_HEADER).evaluateAttributeExpressions(fileToProcess).getValue();
         final String delimiter = 
context.getProperty(HIVEQL_CSV_DELIMITER).evaluateAttributeExpressions(fileToProcess).getValue();
         final boolean quote = 
context.getProperty(HIVEQL_CSV_QUOTE).asBoolean();
-        final boolean escape = 
context.getProperty(HIVEQL_CSV_HEADER).asBoolean();
+        final boolean escape = 
context.getProperty(HIVEQL_CSV_ESCAPE).asBoolean();
         final boolean useLogicalTypes = 
context.getProperty(USE_AVRO_LOGICAL_TYPES).asBoolean();
         final String fragmentIdentifier = UUID.randomUUID().toString();