From commits-return-2938-archive-asf-public=cust-asf.ponee.io@flume.apache.org Thu Nov 22 12:41:36 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id CC78A180675 for ; Thu, 22 Nov 2018 12:41:35 +0100 (CET) Received: (qmail 12693 invoked by uid 500); 22 Nov 2018 11:41:35 -0000 Mailing-List: contact commits-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flume.apache.org Delivered-To: mailing list commits@flume.apache.org Received: (qmail 12683 invoked by uid 99); 22 Nov 2018 11:41:34 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 22 Nov 2018 11:41:34 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 6C6A9E118C; Thu, 22 Nov 2018 11:41:34 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: szaboferee@apache.org To: commits@flume.apache.org Date: Thu, 22 Nov 2018 11:41:35 -0000 Message-Id: In-Reply-To: <290b5ad82e6140c5b865f0600a6deb9a@git.apache.org> References: <290b5ad82e6140c5b865f0600a6deb9a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [2/2] flume git commit: FLUME-2988 Kafka Sink metrics missing eventDrainAttemptCount FLUME-2988 Kafka Sink metrics missing eventDrainAttemptCount Adding missing counter to KafkaSink Reviewers: Denes Arvay, Attila Simon, Ferenc Szabo (Udai Kiran Potluri via Ferenc Szabo) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/1c8c5e67 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/1c8c5e67 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/1c8c5e67 Branch: refs/heads/trunk Commit: 1c8c5e671f29c7e01bf5fc46e4c3b0fe8662addd Parents: 0d2a9f9 Author: Ferenc Szabo Authored: Thu Nov 22 10:51:56 2018 +0100 Committer: Ferenc Szabo Committed: Thu Nov 22 12:41:12 2018 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/kafka/KafkaSink.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/1c8c5e67/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java index 3d56caa..d32753f 100644 --- a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java +++ b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java @@ -172,6 +172,7 @@ public class KafkaSink extends AbstractSink implements Configurable, BatchSizeSu } break; } + counter.incrementEventDrainAttemptCount(); byte[] eventBody = event.getBody(); Map headers = event.getHeaders();