flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mpe...@apache.org
Subject svn commit: r1358399 - /incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
Date Fri, 06 Jul 2012 20:12:51 GMT
Author: mpercy
Date: Fri Jul  6 20:12:51 2012
New Revision: 1358399

URL: http://svn.apache.org/viewvc?rev=1358399&view=rev
Log:
FLUME-1344. Fix JMX connection created count in AvroSink.

(Arvind Prabhakar via Mike Percy)

Modified:
    incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java

Modified: incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java?rev=1358399&r1=1358398&r2=1358399&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
(original)
+++ incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
Fri Jul  6 20:12:51 2012
@@ -179,7 +179,8 @@ public class AvroSink extends AbstractSi
           "port: {}",
           new Object[] { getName(), hostname, port });
       try {
-       client = RpcClientFactory.getInstance(clientProps);
+        client = RpcClientFactory.getInstance(clientProps);
+        sinkCounter.incrementConnectionCreatedCount();
       } catch (Exception ex) {
         sinkCounter.incrementConnectionFailedCount();
         if (ex instanceof FlumeException) {



Mime
View raw message