Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-13 13:34:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1170 from metamx/fix-archive-task

Browse Source 
break up archive task actions
This commit is contained in:
Fangjin Yang 2015-03-04 22:09:00 -08:00
commit 9850b99b3b
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
indexing-service/src/main/java/io/druid/indexing/common/task/ArchiveTask.java
View File

@ -89,20 +89,12 @@ public class ArchiveTask extends AbstractFixedIntervalTask
log.info("OK to archive segment: %s", unusedSegment.getIdentifier()); log.info("OK to archive segment: %s", unusedSegment.getIdentifier());
} }
List<DataSegment> archivedSegments = Lists.newLinkedList();
// Move segments // Move segments
for (DataSegment segment : unusedSegments) { for (DataSegment segment : unusedSegments) {
archivedSegments.add(toolbox.getDataSegmentArchiver().archive(segment)); final DataSegment archivedSegment = toolbox.getDataSegmentArchiver().archive(segment);
toolbox.getTaskActionClient().submit(new SegmentMetadataUpdateAction(ImmutableSet.of(archivedSegment)));
} }
// Update metadata for moved segments
toolbox.getTaskActionClient().submit(
new SegmentMetadataUpdateAction(
ImmutableSet.copyOf(archivedSegments)
)
);
return TaskStatus.success(getId()); return TaskStatus.success(getId());
} }
} }