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

update for new interfaces

This commit is contained in:
Xavier Léauté 2013-12-13 14:29:09 -08:00
parent 3af6e49cd4
commit 123bddd615
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java
View File

@ -36,7 +36,7 @@ import org.joda.time.Interval;
import java.util.List; import java.util.List;
public class MoveTask extends AbstractTask public class MoveTask extends AbstractFixedIntervalTask
{ {
private static final Logger log = new Logger(MoveTask.class); private static final Logger log = new Logger(MoveTask.class);
@ -70,8 +70,8 @@ public class MoveTask extends AbstractTask
throw new ISE("WTF?! Lock dataSource[%s] != task dataSource[%s]", myLock.getDataSource(), getDataSource()); throw new ISE("WTF?! Lock dataSource[%s] != task dataSource[%s]", myLock.getDataSource(), getDataSource());
} }
if(!myLock.getInterval().equals(getImplicitLockInterval().get())) { if(!myLock.getInterval().equals(getInterval())) {
throw new ISE("WTF?! Lock interval[%s] != task interval[%s]", myLock.getInterval(), getImplicitLockInterval().get()); throw new ISE("WTF?! Lock interval[%s] != task interval[%s]", myLock.getInterval(), getInterval());
} }
// List unused segments // List unused segments