[nifi] branch master updated: NIFI-7425 Log Message for ReplaceText Over Buffer Size

[pv...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new effa930  NIFI-7425 Log Message for ReplaceText Over Buffer Size
effa930 is described below

commit effa9301511c0aa9a80d8c9d644a11b073ace15b
Author: Alan Jackoway <al...@cloudera.com>
AuthorDate: Tue May 5 15:42:02 2020 -0400

    NIFI-7425 Log Message for ReplaceText Over Buffer Size
    
    Adds a log message when ReplaceText sends a flowfile to the failure relationship because
    it is larger than the max buffer size.
    
    Signed-off-by: Pierre Villard <pi...@gmail.com>
    
    This closes #4255.
---
 .../src/main/java/org/apache/nifi/processors/standard/ReplaceText.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java
index a75828a..22ba5f8 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java
@@ -315,6 +315,7 @@ public class ReplaceText extends AbstractProcessor {
 
         if (evaluateMode.equalsIgnoreCase(ENTIRE_TEXT)) {
             if (flowFile.getSize() > maxBufferSize && replacementStrategyExecutor.isAllDataBufferedForEntireText()) {
+                logger.warn("Transferred {} to 'faliure' because it was larger than the buffer size");
                 session.transfer(flowFile, REL_FAILURE);
                 return;
             }