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

adding log line for segment being killed in HdfsDataSegmentKiller

This commit is contained in:
Himanshu Gupta 2016-01-15 15:10:16 -06:00
parent 637d2605e7
commit dcd3a24f59
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
extensions/hdfs-storage/src/main/java/io/druid/storage/hdfs/HdfsDataSegmentKiller.java
View File

@ -20,6 +20,7 @@
package io.druid.storage.hdfs; package io.druid.storage.hdfs;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.metamx.common.logger.Logger;
import io.druid.segment.loading.DataSegmentKiller; import io.druid.segment.loading.DataSegmentKiller;
import io.druid.segment.loading.SegmentLoadingException; import io.druid.segment.loading.SegmentLoadingException;
import io.druid.timeline.DataSegment; import io.druid.timeline.DataSegment;
@ -31,6 +32,10 @@ import java.io.IOException;
public class HdfsDataSegmentKiller implements DataSegmentKiller public class HdfsDataSegmentKiller implements DataSegmentKiller
{ {
private static final Logger log = new Logger(HdfsDataSegmentKiller.class);
private static final String PATH_KEY = "path";
private final Configuration config; private final Configuration config;
@Inject @Inject
@ -43,6 +48,8 @@ public class HdfsDataSegmentKiller implements DataSegmentKiller
public void kill(DataSegment segment) throws SegmentLoadingException public void kill(DataSegment segment) throws SegmentLoadingException
{ {
final Path path = getPath(segment); final Path path = getPath(segment);
log.info("killing segment[%s] mapped to path[%s]", segment.getIdentifier(), path);
final FileSystem fs = checkPathAndGetFilesystem(path); final FileSystem fs = checkPathAndGetFilesystem(path);
try { try {
if (path.getName().endsWith(".zip")) { if (path.getName().endsWith(".zip")) {
@ -86,7 +93,7 @@ public class HdfsDataSegmentKiller implements DataSegmentKiller
private Path getPath(DataSegment segment) private Path getPath(DataSegment segment)
{ {
return new Path(String.valueOf(segment.getLoadSpec().get("path"))); return new Path(String.valueOf(segment.getLoadSpec().get(PATH_KEY)));
} }
private FileSystem checkPathAndGetFilesystem(Path path) throws SegmentLoadingException private FileSystem checkPathAndGetFilesystem(Path path) throws SegmentLoadingException