fix broken ut

This commit is contained in:
fjy 2014-06-17 10:31:50 -07:00
parent d3ed08e8ea
commit 8a13e34c50
2 changed files with 4 additions and 2 deletions

View File

@ -135,7 +135,7 @@ public class TaskLifecycleTest
mdc = newMockMDC(); mdc = newMockMDC();
tac = new LocalTaskActionClientFactory(ts, new TaskActionToolbox(tl, mdc, newMockEmitter())); tac = new LocalTaskActionClientFactory(ts, new TaskActionToolbox(tl, mdc, newMockEmitter()));
tb = new TaskToolboxFactory( tb = new TaskToolboxFactory(
new TaskConfig(tmp.toString(), null, null, 50000), new TaskConfig(tmp.toString(), null, null, 50000, null),
tac, tac,
newMockEmitter(), newMockEmitter(),
new DataSegmentPusher() new DataSegmentPusher()

View File

@ -183,6 +183,8 @@ public class DruidClusterBridgeTest
EasyMock.expectLastCall(); EasyMock.expectLastCall();
batchServerInventoryView.start(); batchServerInventoryView.start();
EasyMock.expectLastCall(); EasyMock.expectLastCall();
batchServerInventoryView.stop();
EasyMock.expectLastCall();
EasyMock.replay(batchServerInventoryView); EasyMock.replay(batchServerInventoryView);
@ -229,10 +231,10 @@ public class DruidClusterBridgeTest
Assert.assertEquals(118, announced.getMaxSize()); Assert.assertEquals(118, announced.getMaxSize());
bridge.stop();
EasyMock.verify(batchServerInventoryView); EasyMock.verify(batchServerInventoryView);
announcer.stop(); announcer.stop();
bridge.stop();
remoteCf.close(); remoteCf.close();
remoteCluster.close(); remoteCluster.close();