Repository: nifi Updated Branches: refs/heads/0.x 663a03541 -> 8e190512f refs/heads/master d6674fbb8 -> afc8c645a
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/afc8c645 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/afc8c645 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/afc8c645 Branch: refs/heads/master Commit: afc8c645a10d0ccd5c0a6c81d319d238fc4c765b Parents: d6674fb Author: DomenicPuzio <[email protected]> Authored: Mon May 16 00:27:06 2016 -0400 Committer: Aldrin Piri <[email protected]> Committed: Thu May 19 16:21:45 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/afc8c645/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 5cce470..4fcd79a 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/afc8c645/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 8fb5996..f41941d 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; }
