This is an automated email from the ASF dual-hosted git repository. ppkarwasz pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/logging-flume-legacy.git
commit 3c0bbbbb9a402badaa23aae6150d74c99b1a67c4 Author: Arvind Prabhakar <[email protected]> AuthorDate: Thu Mar 29 01:58:53 2012 +0000 FLUME-962. Failover capability for Client SDK. (Hari Shreedharan via Arvind Prabhakar) git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/trunk@1306687 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java b/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java index 5bc0472..083f5d1 100644 --- a/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java +++ b/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java @@ -181,7 +181,7 @@ public class Log4jAppender extends AppenderSkeleton { @Override public void activateOptions() throws FlumeException{ try { - rpcClient = RpcClientFactory.getInstance(hostname, port); + rpcClient = RpcClientFactory.getDefaultInstance(hostname, port); } catch (FlumeException e) { String errormsg = "RPC client creation failed! " + e.getMessage();
