Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Another try to fix xxServerViewTests

This commit is contained in:
navis.ryu 2015-12-23 17:25:08 +09:00
parent 508629916d
commit 2c3c4a3f8f
14 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
indexing-service/src/test/java/io/druid/indexing/overlord/RemoteTaskRunnerTest.java
View File

@ -99,6 +99,7 @@ public class RemoteTaskRunnerTest
.compressionProvider(new PotentiallyGzippedCompressionProvider(false))
.build();
cf.start();
cf.blockUntilConnected();
cf.create().creatingParentsIfNeeded().forPath(basePath);
cf.create().creatingParentsIfNeeded().forPath(tasksPath);

1
indexing-service/src/test/java/io/druid/indexing/overlord/http/OverlordResourceTest.java
View File

@ -146,6 +146,7 @@ public class OverlordResourceTest
IndexerZkConfig indexerZkConfig = new IndexerZkConfig(new ZkPathsConfig(), null, null, null, null, null);
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
curator.create().creatingParentsIfNeeded().forPath(indexerZkConfig.getLeaderLatchPath());
druidNode = new DruidNode("hey", "what", 1234);
ServiceEmitter serviceEmitter = new NoopServiceEmitter();

1
indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java
View File

@ -102,6 +102,7 @@ public class WorkerTaskMonitorTest
.compressionProvider(new PotentiallyGzippedCompressionProvider(false))
.build();
cf.start();
cf.blockUntilConnected();
cf.create().creatingParentsIfNeeded().forPath(basePath);
worker = new Worker(

1
indexing-service/src/test/java/io/druid/indexing/worker/http/WorkerResourceTest.java
View File

@ -66,6 +66,7 @@ public class WorkerResourceTest
.compressionProvider(new PotentiallyGzippedCompressionProvider(false))
.build();
cf.start();
cf.blockUntilConnected();
cf.create().creatingParentsIfNeeded().forPath(basePath);
worker = new Worker(

1
server/src/test/java/io/druid/client/BrokerServerViewTest.java
View File

@ -81,6 +81,7 @@ public class BrokerServerViewTest extends CuratorTestBase
{
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
}
@Test

1
server/src/test/java/io/druid/client/CoordinatorServerViewTest.java
View File

@ -73,6 +73,7 @@ public class CoordinatorServerViewTest extends CuratorTestBase
{
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
}
@Test

1
server/src/test/java/io/druid/client/client/BatchServerInventoryViewTest.java
View File

@ -96,6 +96,7 @@ public class BatchServerInventoryViewTest
.compressionProvider(new PotentiallyGzippedCompressionProvider(true))
.build();
cf.start();
cf.blockUntilConnected();
cf.create().creatingParentsIfNeeded().forPath(testBasePath);
jsonMapper = new DefaultObjectMapper();

3
server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java
View File

@ -184,6 +184,7 @@ public class AnnouncerTest extends CuratorTestBase
public void testCleansUpItsLittleTurdlings() throws Exception
{
curator.start();
curator.blockUntilConnected();
Announcer announcer = new Announcer(curator, exec);
final byte[] billy = "billy".getBytes();
@ -209,6 +210,7 @@ public class AnnouncerTest extends CuratorTestBase
public void testLeavesBehindTurdlingsThatAlreadyExisted() throws Exception
{
curator.start();
curator.blockUntilConnected();
Announcer announcer = new Announcer(curator, exec);
final byte[] billy = "billy".getBytes();
@ -237,6 +239,7 @@ public class AnnouncerTest extends CuratorTestBase
public void testLeavesBehindTurdlingsWhenToldTo() throws Exception
{
curator.start();
curator.blockUntilConnected();
Announcer announcer = new Announcer(curator, exec);
final byte[] billy = "billy".getBytes();

2
server/src/test/java/io/druid/curator/discovery/ServiceAnnouncerTest.java
View File

@ -46,6 +46,7 @@ public class ServiceAnnouncerTest extends CuratorTestBase
public void testServiceAnnouncement() throws Exception
{
curator.start();
curator.blockUntilConnected();
List<String> serviceNames = ImmutableList.of(
"druid/overlord",
"druid/coordinator",
@ -79,6 +80,7 @@ public class ServiceAnnouncerTest extends CuratorTestBase
public void testServiceAnnouncementFail() throws Exception
{
curator.start();
curator.blockUntilConnected();
createAndAnnounceServices(ImmutableList.of("placeholder/\u0001"));
}

2
server/src/test/java/io/druid/curator/inventory/CuratorInventoryManagerTest.java
View File

@ -66,6 +66,8 @@ public class CuratorInventoryManagerTest extends io.druid.curator.CuratorTestBas
);
curator.start();
curator.blockUntilConnected();
manager.start();
Assert.assertTrue(Iterables.isEmpty(manager.getInventory()));

1
server/src/test/java/io/druid/server/coordination/ZkCoordinatorTest.java
View File

@ -79,6 +79,7 @@ public class ZkCoordinatorTest extends CuratorTestBase
{
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
try {
infoDir = new File(File.createTempFile("blah", "blah2").getParent(), "ZkCoordinatorTest");
infoDir.mkdirs();

1
server/src/test/java/io/druid/server/coordination/coordination/BatchDataSegmentAnnouncerTest.java
View File

@ -76,6 +76,7 @@ public class BatchDataSegmentAnnouncerTest
.compressionProvider(new PotentiallyGzippedCompressionProvider(false))
.build();
cf.start();
cf.blockUntilConnected();
cf.create().creatingParentsIfNeeded().forPath(testBasePath);
jsonMapper = new DefaultObjectMapper();

1
server/src/test/java/io/druid/server/coordinator/DruidCoordinatorTest.java
View File

@ -112,6 +112,7 @@ public class DruidCoordinatorTest extends CuratorTestBase
EasyMock.replay(configManager);
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
curator.create().creatingParentsIfNeeded().forPath(LOADPATH);
objectMapper = new DefaultObjectMapper();
druidCoordinatorConfig = new TestDruidCoordinatorConfig(new Duration(COORDINATOR_START_DELAY), new Duration(COORDINATOR_PERIOD), null, null, null, false, false);

1
server/src/test/java/io/druid/server/coordinator/LoadQueuePeonTest.java
View File

@ -64,6 +64,7 @@ public class LoadQueuePeonTest extends CuratorTestBase
{
setupServerAndCurator();
curator.start();
curator.blockUntilConnected();
curator.create().creatingParentsIfNeeded().forPath(LOAD_QUEUE_PATH);
loadQueueCache = new PathChildrenCache(