You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by oz...@apache.org on 2016/04/04 19:58:21 UTC
[3/9] nifi git commit: NIFI-1684 added penalization on failure
NIFI-1684 added penalization on failure
Signed-off-by: joewitt <jo...@apache.org>
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 <ol...@suitcase.io>
Authored: Thu Mar 24 15:29:35 2016 -0400
Committer: Oleg Zhurakousky <ol...@suitcase.io>
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 {