}
public QueryOperation() {
}
@Override
public void run() throws Exception {
<BUG>List<Integer> initialPartitions = mapService.getOwnedPartitions().get();
IndexService indexService = mapService.getMapContainer(name).getIndexService();</BUG>
Set<QueryableEntry> entries = null;
if (!getNodeEngine().getPartitionService().hasOnGoingMigration()) {
entries = indexService.query(predicate);

}
public QueryOperation() {
}
@Override
public void run() throws Exception {
List<Integer> initialPartitions = mapService.getOwnedPartitions();
IndexService indexService = mapService.getMapContainer(name).getIndexService();
Set<QueryableEntry> entries = null;
if (!getNodeEngine().getPartitionService().hasOnGoingMigration()) {
entries = indexService.query(predicate);
