You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2012/07/06 22:12:51 UTC
svn commit: r1358399 -
/incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
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) {