Github user pvillard31 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2138#discussion_r160469685
--- Diff:
nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java
---
@@ -232,6 +233,13 @@ private FunctionContext(boolean rollbackOnFailure,
Charset charset, String state
getLogger().warn("Failed to parse hiveQL: {} due
to {}", new Object[]{hiveQL, e}, e);
}
+ try {
+ // set query timeout
+
stmt.setQueryTimeout(context.getProperty(QUERY_TIMEOUT).evaluateAttributeExpressions(flowFile).asInteger());
--- End diff --
Oh right, forgot about EL! I think best is to keep current behavior with an
exception and rollback but with another logging statement. I'll push a commit
for that.
---
