From 3d8179db1290dffe773b82a65c5ea77bc353b06a Mon Sep 17 00:00:00 2001 From: Andre F de Miranda Date: Sat, 1 Apr 2017 17:15:13 +1100 Subject: [PATCH] NIFI-1336 - Ensure that flowfiles are penalized upon exception due to inability to delete hold --- .../java/org/apache/nifi/processors/standard/PostHTTP.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java index badc7516b9e4..10bcb0cbd3d5 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java @@ -866,6 +866,10 @@ public long getContentLength() { return; } catch (final IOException e) { logger.warn("Failed to delete Hold that destination placed on {} due to {}", new Object[]{flowFileDescription, e}); + for (FlowFile flowFile : toSend) { + flowFile = session.penalize(flowFile); + session.transfer(flowFile, REL_FAILURE); + } } if (!isScheduled()) {