NIFI-1684 added penalization on failure Signed-off-by: joewitt <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/7561fa53 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/7561fa53 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/7561fa53 Branch: refs/heads/support/nifi-0.6.x Commit: 7561fa53e4e7ca4e3256d0de8491cc6e5b93f76e Parents: f0546d0 Author: Oleg Zhurakousky <[email protected]> Authored: Thu Mar 24 15:29:35 2016 -0400 Committer: Oleg Zhurakousky <[email protected]> Committed: Mon Apr 4 13:52:35 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kafka/PutKafka.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/7561fa53/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java index 513f4f3..44f04aa 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java @@ -306,7 +306,7 @@ public class PutKafka extends AbstractProcessor { session.transfer(flowFile, REL_SUCCESS); } else { flowFile = session.putAllAttributes(flowFile, this.buildFailedFlowFileAttributes(failedSegmentsRef.get(), messageContext)); - session.transfer(flowFile, REL_FAILURE); + session.transfer(session.penalize(flowFile), REL_FAILURE); } } else {
