From 158a24c05a2350f902cf4e88399217435ab9f00c Mon Sep 17 00:00:00 2001 From: xxl072 Date: Mon, 16 May 2016 00:27:06 -0400 Subject: [PATCH] NIFI-1498: putFile - Flowfiles routed to failure relationship produce INFO level log messages --- .../java/org/apache/nifi/processors/standard/PutFile.java | 4 ++-- .../apache/nifi/processors/standard/PutFileTransfer.java | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) 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 d32427e086de..5b819b3d7430 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 void onTrigger(final ProcessContext context, final ProcessSession session 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 void onTrigger(final ProcessContext context, final ProcessSession session 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: 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 c03f755ea753..7c9da5c301c0 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 @@ private ConflictResult identifyAndResolveConflictFile( } 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 @@ private ConflictResult identifyAndResolveConflictFile( 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 @@ private ConflictResult identifyAndResolveConflictFile( 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 @@ private ConflictResult identifyAndResolveConflictFile( 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; }