File tree Expand file tree Collapse file tree 1 file changed +7
-8
lines changed
client/src/main/java/com/alibaba/otter/canal/client/impl Expand file tree Collapse file tree 1 file changed +7
-8
lines changed Original file line number Diff line number Diff line change 1
1
package com .alibaba .otter .canal .client .impl ;
2
2
3
- import java .net .SocketAddress ;
4
- import java .util .concurrent .TimeUnit ;
5
-
6
- import org .slf4j .Logger ;
7
- import org .slf4j .LoggerFactory ;
8
-
9
3
import com .alibaba .otter .canal .client .CanalConnector ;
10
4
import com .alibaba .otter .canal .client .CanalNodeAccessStrategy ;
11
5
import com .alibaba .otter .canal .protocol .Message ;
12
6
import com .alibaba .otter .canal .protocol .exception .CanalClientException ;
7
+ import org .slf4j .Logger ;
8
+ import org .slf4j .LoggerFactory ;
9
+
10
+ import java .net .SocketAddress ;
11
+ import java .util .concurrent .TimeUnit ;
13
12
14
13
/**
15
14
* 集群版本connector实现,自带了failover功能<br/>
16
- *
15
+ *
17
16
* @author jianghang 2012-10-29 下午08:04:06
18
17
* @version 1.0.0
19
18
*/
@@ -65,7 +64,7 @@ public SocketAddress getNextAddress() {
65
64
currentConnector .connect ();
66
65
break ;
67
66
} catch (Exception e ) {
68
- logger .warn ("failed to connect to:{} after retry {} times" , accessStrategy . currentNode () , times );
67
+ logger .warn ("failed to connect to canal server after retry {} times" , times );
69
68
currentConnector .disconnect ();
70
69
currentConnector = null ;
71
70
// retry for #retryTimes for each node when trying to
You can’t perform that action at this time.
0 commit comments