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

1) Indexes don't always have an index.drd file anymore

This commit is contained in:
Eric Tschetter 2013-01-23 18:36:52 -06:00
parent 689ce4f8e1
commit 67feee3cd6
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/src/main/java/com/metamx/druid/loading/MMappedQueryableIndexFactory.java
View File

@ -36,11 +36,6 @@ public class MMappedQueryableIndexFactory implements QueryableIndexFactory
@Override
public QueryableIndex factorize(File parentDir) throws StorageAdapterLoadingException
{
File indexFile = new File(parentDir, "index.drd");
if (!indexFile.exists()) {
throw new StorageAdapterLoadingException("indexFile[%s] does not exist.", indexFile);
}
try {
if (! IndexIO.canBeMapped(parentDir)) {
File canBeMappedDir = new File(parentDir, "forTheMapping");
@ -55,7 +50,7 @@ public class MMappedQueryableIndexFactory implements QueryableIndexFactory
}
for (File file : canBeMappedDir.listFiles()) {
if (! file.renameTo(new File(parentDir, file.getName()))) {
throw new StorageAdapterLoadingException("Couldn't rename[%s] to [%s]", canBeMappedDir, indexFile);
throw new StorageAdapterLoadingException("Couldn't rename[%s] to [%s]", canBeMappedDir, parentDir);
}
}
FileUtils.deleteDirectory(canBeMappedDir);
@ -64,7 +59,7 @@ public class MMappedQueryableIndexFactory implements QueryableIndexFactory
return IndexIO.loadIndex(parentDir);
}
catch (IOException e) {
log.warn(e, "Got exception, deleting index[%s]", indexFile);
log.warn(e, "Got exception, deleting parentDir[%s]", parentDir);
try {
FileUtils.deleteDirectory(parentDir);
}