You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tk...@apache.org on 2016/02/18 02:59:47 UTC
nifi git commit: NIFI-1063 Fixed exception logging
Repository: nifi
Updated Branches:
refs/heads/master c2998a71e -> 502aebc66
NIFI-1063 Fixed exception logging
Fixed logging of an exception in PutHDFS
Reviewed by Tony Kurc (tkurc@apache.org). This closes #226
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/502aebc6
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/502aebc6
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/502aebc6
Branch: refs/heads/master
Commit: 502aebc66aba2731949f7d482ac7c5285c9dfff6
Parents: c2998a7
Author: Pierre Villard <pi...@gmail.com>
Authored: Tue Feb 16 12:34:26 2016 +0100
Committer: Tony Kurc <tr...@gmail.com>
Committed: Wed Feb 17 20:59:31 2016 -0500
----------------------------------------------------------------------
.../src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/502aebc6/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java
index f7f4d03..0c36928 100644
--- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java
+++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java
@@ -344,7 +344,7 @@ public class PutHDFS extends AbstractHadoopProcessor {
getLogger().error("Unable to remove temporary file {} due to {}", new Object[]{tempDotCopyFile, e});
}
}
- getLogger().error("Failed to write to HDFS due to {}", t);
+ getLogger().error("Failed to write to HDFS due to {}", new Object[]{t});
session.transfer(session.penalize(flowFile), REL_FAILURE);
context.yield();
}