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

RealtimeIndexTask: Fix "resource" serde

This commit is contained in:
Gian Merlino 2013-08-20 13:02:52 -07:00
parent ddcc1b53e0
commit d8493f8e26
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
indexing-service/src/main/java/com/metamx/druid/indexing/common/task/AbstractTask.java
View File

@ -88,7 +88,7 @@ public abstract class AbstractTask implements Task
return groupId;
}
@JsonProperty
@JsonProperty("resource")
@Override
public TaskResource getTaskResource()
{

4
indexing-service/src/test/java/com/metamx/druid/indexing/common/task/TaskSerdeTest.java
View File

@ -202,7 +202,7 @@ public class TaskSerdeTest
{
final Task task = new RealtimeIndexTask(
null,
null,
new TaskResource("rofl", 2),
new Schema("foo", null, new AggregatorFactory[0], QueryGranularity.NONE, new NoneShardSpec()),
null,
null,
@ -221,6 +221,8 @@ public class TaskSerdeTest
Assert.assertEquals(Optional.<Interval>absent(), task.getImplicitLockInterval());
Assert.assertEquals(new Period("PT10M"), ((RealtimeIndexTask) task).getWindowPeriod());
Assert.assertEquals(IndexGranularity.HOUR, ((RealtimeIndexTask) task).getSegmentGranularity());
Assert.assertEquals(2, task.getTaskResource().getRequiredCapacity());
Assert.assertEquals("rofl", task.getTaskResource().getAvailabilityGroup());
Assert.assertEquals(task.getId(), task2.getId());
Assert.assertEquals(task.getGroupId(), task2.getGroupId());