Github user bdesert commented on a diff in the pull request: https://github.com/apache/nifi/pull/2695#discussion_r189075604 --- Diff: nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java --- @@ -311,7 +340,15 @@ private void onTrigger(final ProcessContext context, final ProcessSession sessio try (final Connection con = dbcpService.getConnection(fileToProcess == null ? Collections.emptyMap() : fileToProcess.getAttributes()); final Statement st = (flowbased ? con.prepareStatement(selectQuery) : con.createStatement()) ) { - + Pair<String,SQLException> failure = executeConfigStatements(con, preQueries); + if (failure != null) { + // In case of failure, assigning config query to "selectQuery" var will allow to avoid major changes in error handling (catch block), --- End diff -- @pvillard31 , I think if I just rename this var into "hqlStatement" - that will remove confusions and make reusing it for pre- and post- queries natural. Going to push updates for this.
---