NIFI-1498: putFile - Flowfiles routed to failure relationship produce INFO level log messages
This closes #445. Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/8e190512 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/8e190512 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/8e190512 Branch: refs/heads/0.x Commit: 8e190512f82f7f19fd67d1b7c2920cef2a22322a Parents: 663a035 Author: DomenicPuzio <[email protected]> Authored: Mon May 16 00:27:06 2016 -0400 Committer: Aldrin Piri <[email protected]> Committed: Thu May 19 16:21:54 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/PutFile.java | 4 ++-- .../org/apache/nifi/processors/standard/PutFileTransfer.java | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/8e190512/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFile.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFile.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFile.java index d32427e..5b819b3 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFile.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFile.java @@ -213,7 +213,7 @@ public class PutFile extends AbstractProcessor { if (numFiles >= maxDestinationFiles) { flowFile = session.penalize(flowFile); - logger.info("Penalizing {} and routing to 'failure' because the output directory {} has {} files, which exceeds the " + logger.warn("Penalizing {} and routing to 'failure' because the output directory {} has {} files, which exceeds the " + "configured maximum number of files", new Object[]{flowFile, finalCopyFileDir, numFiles}); session.transfer(flowFile, REL_FAILURE); return; @@ -232,7 +232,7 @@ public class PutFile extends AbstractProcessor { return; case FAIL_RESOLUTION: flowFile = session.penalize(flowFile); - logger.info("Penalizing {} and routing to failure as configured because file with the same name already exists", new Object[]{flowFile}); + logger.warn("Penalizing {} and routing to failure as configured because file with the same name already exists", new Object[]{flowFile}); session.transfer(flowFile, REL_FAILURE); return; default: http://git-wip-us.apache.org/repos/asf/nifi/blob/8e190512/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java index c03f755..7c9da5c 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java @@ -215,7 +215,7 @@ public abstract class PutFileTransfer<T extends FileTransfer> extends AbstractPr } if (remoteFileInfo.isDirectory()) { - logger.info("Resolving conflict by rejecting {} due to conflicting filename with a directory or file already on remote server", new Object[]{flowFile}); + logger.warn("Resolving conflict by rejecting {} due to conflicting filename with a directory or file already on remote server", new Object[]{flowFile}); return new ConflictResult(REL_REJECT, false, fileName, false); } @@ -227,7 +227,7 @@ public abstract class PutFileTransfer<T extends FileTransfer> extends AbstractPr destinationRelationship = REL_REJECT; transferFile = false; penalizeFile = false; - logger.info("Resolving conflict by rejecting {} due to conflicting filename with a directory or file already on remote server", new Object[]{flowFile}); + logger.warn("Resolving conflict by rejecting {} due to conflicting filename with a directory or file already on remote server", new Object[]{flowFile}); break; case FileTransfer.CONFLICT_RESOLUTION_REPLACE: transfer.deleteFile(path, fileName); @@ -256,7 +256,7 @@ public abstract class PutFileTransfer<T extends FileTransfer> extends AbstractPr destinationRelationship = REL_REJECT; transferFile = false; penalizeFile = false; - logger.info("Could not determine a unique name after 99 attempts for. Switching resolution mode to REJECT for " + flowFile); + logger.warn("Could not determine a unique name after 99 attempts for. Switching resolution mode to REJECT for " + flowFile); } break; case FileTransfer.CONFLICT_RESOLUTION_IGNORE: @@ -269,7 +269,7 @@ public abstract class PutFileTransfer<T extends FileTransfer> extends AbstractPr destinationRelationship = REL_FAILURE; transferFile = false; penalizeFile = true; - logger.info("Resolved filename conflict for {} as configured by routing to FAILURE relationship.", new Object[]{flowFile}); + logger.warn("Resolved filename conflict for {} as configured by routing to FAILURE relationship.", new Object[]{flowFile}); default: break; }
