flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From szabofe...@apache.org
Subject [2/2] flume git commit: FLUME-2988 Kafka Sink metrics missing eventDrainAttemptCount
Date Thu, 22 Nov 2018 11:41:35 GMT
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 <szaboferee@apache.org>
Authored: Thu Nov 22 10:51:56 2018 +0100
Committer: Ferenc Szabo <szaboferee@apache.org>
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<String, String> headers = event.getHeaders();


Mime
View raw message