flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject svn commit: r1354263 - /incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
Date Tue, 26 Jun 2012 22:10:48 GMT
Author: hshreedharan
Date: Tue Jun 26 22:10:48 2012
New Revision: 1354263

URL: http://svn.apache.org/viewvc?rev=1354263&view=rev
Log:
FLUME-1306. LoadBalancingRpcClient should catch exception for invalid RpcClient and failover
to valid one.

(Mubarak Seyed via Hari Shreedharan)


Modified:
    incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java

Modified: incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java?rev=1354263&r1=1354262&r2=1354263&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
(original)
+++ incubator/flume/trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
Tue Jun 26 22:10:48 2012
@@ -66,8 +66,8 @@ public class LoadBalancingRpcClient exte
 
     while (it.hasNext()) {
       HostInfo host = it.next();
-      RpcClient client = getClient(host);
       try {
+        RpcClient client = getClient(host);
         client.append(event);
         eventSent = true;
         break;



Mime
View raw message