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 ([email protected]). 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 <[email protected]> Authored: Tue Feb 16 12:34:26 2016 +0100 Committer: Tony Kurc <[email protected]> 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(); }
