diff --git a/server/src/main/java/com/metamx/druid/loading/S3SegmentKiller.java b/server/src/main/java/com/metamx/druid/loading/S3SegmentKiller.java index 801e16a1602..add1d45824e 100644 --- a/server/src/main/java/com/metamx/druid/loading/S3SegmentKiller.java +++ b/server/src/main/java/com/metamx/druid/loading/S3SegmentKiller.java @@ -52,6 +52,8 @@ public class S3SegmentKiller implements SegmentKiller @Override public List kill(final String datasource, final Interval interval) throws ServiceException { + // TODO -- Awkward for workers to use the DB! + List matchingSegments = dbi.withHandle( new HandleCallback>() {