You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mt...@apache.org on 2018/06/14 11:10:04 UTC
nifi git commit: NIFI-5309 update the logger message to get the
output format from the outputFormat variable
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 <mi...@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 <am...@gmail.com>
Authored: Thu Jun 14 11:46:46 2018 +0530
Committer: Mike Thomsen <mi...@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()) {