chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed tescase failed

Browse Source
This commit is contained in:
agapple
2019-08-31 13:00:31 +08:00
parent 456945fe3a
commit a60ec6fa42
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java
View File

@@ -111,8 +111,7 @@ public class ServerRunningTest extends AbstractZkTest {
sleep(30000L); sleep(30000L);
} }
private ServerRunningMonitor buildServerRunning(final CountDownLatch countLatch, final final String ip, private ServerRunningMonitor buildServerRunning(final CountDownLatch countLatch, final String ip, final int port) {
final int port) {
ServerRunningData serverData = new ServerRunningData(ip + ":" + port); ServerRunningData serverData = new ServerRunningData(ip + ":" + port);
ServerRunningMonitor runningMonitor = new ServerRunningMonitor(serverData); ServerRunningMonitor runningMonitor = new ServerRunningMonitor(serverData);
runningMonitor.setDestination(destination); runningMonitor.setDestination(destination);