Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-03-08 10:30:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix sporadic fail of WorkerTaskMonitorTest#testRunTask

Browse Source
This commit is contained in:
navis.ryu 2015-12-24 02:31:30 +09:00
parent 508629916d
commit a8f6c6110d
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -202,10 +202,6 @@ public class WorkerTaskMonitorTest
@Test
public void testRunTask() throws Exception
{
cf.create()
.creatingParentsIfNeeded()
.forPath(joiner.join(tasksPath, task.getId()), jsonMapper.writeValueAsBytes(task));
Assert.assertTrue(
TestUtils.conditionValid(
new IndexingServiceCondition()
@ -224,6 +220,10 @@ public class WorkerTaskMonitorTest
)
);
cf.create()
.creatingParentsIfNeeded()
.forPath(joiner.join(tasksPath, task.getId()), jsonMapper.writeValueAsBytes(task));
Assert.assertTrue(
TestUtils.conditionValid(
new IndexingServiceCondition()
@ -339,7 +339,7 @@ public class WorkerTaskMonitorTest
}
)
);
// ephermal owner is 0 is created node is PERSISTENT
// ephemeral owner is 0 is created node is PERSISTENT
Assert.assertEquals(0, cf.checkExists().forPath(joiner.join(statusPath, task.getId())).getEphemeralOwner());
}