Repository: nifi Updated Branches: refs/heads/master 4349a8e07 -> 8370a56dc
NIFI-5309 update the logger message to get the output format from the outputFormat variable This closes #2793 Signed-off-by: Mike Thomsen <mikerthom...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/8370a56d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/8370a56d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/8370a56d Branch: refs/heads/master Commit: 8370a56dce0432e01fe2ad5d4a712c0fde081b0e Parents: 4349a8e Author: amitt90 <amit...@gmail.com> Authored: Thu Jun 14 11:46:46 2018 +0530 Committer: Mike Thomsen <mikerthom...@gmail.com> Committed: Thu Jun 14 07:09:23 2018 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/hive/SelectHiveQL.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/8370a56d/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java index 74855a1..b811278 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/SelectHiveQL.java @@ -407,7 +407,7 @@ public class SelectHiveQL extends AbstractHiveQLProcessor { flowfile = session.putAllAttributes(flowfile, attributes); - logger.info("{} contains {} Avro records; transferring to 'success'", + logger.info("{} contains {} " + outputFormat + " records; transferring to 'success'", new Object[]{flowfile, nrOfRows.get()}); if (context.hasIncomingConnection()) {