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/07 00:30:22 UTC
svn commit: r1358462 -
/incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
Author: mpercy
Date: Fri Jul 6 22:30:22 2012
New Revision: 1358462
URL: http://svn.apache.org/viewvc?rev=1358462&view=rev
Log:
FLUME-1344. Fix JMX connection created count in AvroSink.
(Arvind Prabhakar via Mike Percy)
Modified:
incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
Modified: incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java?rev=1358462&r1=1358461&r2=1358462&view=diff
==============================================================================
--- incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java (original)
+++ incubator/flume/branches/branch-1.2.0/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java Fri Jul 6 22:30:22 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) {