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

fix NPE

This commit is contained in:
fjy 2013-05-12 15:14:57 -07:00
parent 8e38a85788
commit bcfeac2d8c
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/main/java/com/metamx/druid/coordination/ServerManager.java
View File

@ -20,6 +20,7 @@
package com.metamx.druid.coordination;
import com.google.common.base.Function;
import com.google.common.base.Predicate;
import com.google.common.collect.Ordering;
import com.metamx.common.ISE;
import com.metamx.common.guava.FunctionalIterable;
@ -257,6 +258,16 @@ public class ServerManager implements QuerySegmentWalker
);
}
}
)
.filter(
new Predicate<QueryRunner<T>>()
{
@Override
public boolean apply(@Nullable QueryRunner<T> input)
{
return (input != null);
}
}
);
return new FinalizeResultsQueryRunner<T>(toolChest.mergeResults(factory.mergeRunners(exec, adapters)), toolChest);