From 123bddd6151339c6cc38e05822c221071cff8c62 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Fri, 13 Dec 2013 14:29:09 -0800 Subject: [PATCH] update for new interfaces --- .../main/java/io/druid/indexing/common/task/MoveTask.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java index 4ca600f8ea5..3154d42075d 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/task/MoveTask.java @@ -36,7 +36,7 @@ import org.joda.time.Interval; import java.util.List; -public class MoveTask extends AbstractTask +public class MoveTask extends AbstractFixedIntervalTask { 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()); } - if(!myLock.getInterval().equals(getImplicitLockInterval().get())) { - throw new ISE("WTF?! Lock interval[%s] != task interval[%s]", myLock.getInterval(), getImplicitLockInterval().get()); + if(!myLock.getInterval().equals(getInterval())) { + throw new ISE("WTF?! Lock interval[%s] != task interval[%s]", myLock.getInterval(), getInterval()); } // List unused segments