diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveStreaming.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveStreaming.java index 40ba9e2874..450f157902 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveStreaming.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveStreaming.java @@ -182,6 +182,7 @@ public class PutHiveStreaming extends AbstractSessionFactoryProcessor { + "Please see the Hive documentation for more details.") .required(false) .addValidator(HiveUtils.createMultipleFilesExistValidator()) + .expressionLanguageSupported(ExpressionLanguageScope.VARIABLE_REGISTRY) .build(); public static final PropertyDescriptor DB_NAME = new PropertyDescriptor.Builder() @@ -424,7 +425,7 @@ public class PutHiveStreaming extends AbstractSessionFactoryProcessor { ComponentLog log = getLogger(); final Integer heartbeatInterval = context.getProperty(HEARTBEAT_INTERVAL).evaluateAttributeExpressions().asInteger(); - final String configFiles = context.getProperty(HIVE_CONFIGURATION_RESOURCES).getValue(); + final String configFiles = context.getProperty(HIVE_CONFIGURATION_RESOURCES).evaluateAttributeExpressions().getValue(); hiveConfig = hiveConfigurator.getConfigurationFromFiles(configFiles); // If more than one concurrent task, force 'hcatalog.hive.client.cache.disabled' to true diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java index 6e87771f6a..82843cf109 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java @@ -133,6 +133,7 @@ public class PutHive3Streaming extends AbstractProcessor { + "Please see the Hive documentation for more details.") .required(false) .addValidator(HiveUtils.createMultipleFilesExistValidator()) + .expressionLanguageSupported(ExpressionLanguageScope.VARIABLE_REGISTRY) .build(); static final PropertyDescriptor DB_NAME = new PropertyDescriptor.Builder() @@ -301,7 +302,7 @@ public class PutHive3Streaming extends AbstractProcessor { ComponentLog log = getLogger(); rollbackOnFailure = context.getProperty(ROLLBACK_ON_FAILURE).asBoolean(); - final String configFiles = context.getProperty(HIVE_CONFIGURATION_RESOURCES).getValue(); + final String configFiles = context.getProperty(HIVE_CONFIGURATION_RESOURCES).evaluateAttributeExpressions().getValue(); hiveConfig = hiveConfigurator.getConfigurationFromFiles(configFiles); // If more than one concurrent task, force 'hcatalog.hive.client.cache.disabled' to true