Github user pvillard31 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2138#discussion_r159671901
--- Diff:
nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java
---
@@ -233,6 +234,7 @@ private FunctionContext(boolean rollbackOnFailure,
Charset charset, String state
}
// Execute the statement
+
stmt.setQueryTimeout(context.getProperty(QUERY_TIMEOUT).evaluateAttributeExpressions(flowFile).asInteger());
--- End diff --
Good catch, just pushed a commit for PutHiveQL and SelectHiveQL. Thanks!
---
