increase timeout for executor thread
@@ -64,7 +64,7 @@ public class TriplesMapPlanExecutor {
List<Future<Boolean>> results = service.invokeAll(plan.workers);
for(Future<Boolean> result : results)
{
- result.get(1, TimeUnit.MINUTES);
+ result.get(10, TimeUnit.MINUTES);
}
}
else
@@ -81,7 +81,7 @@ public class TriplesMapPlanExecutor {
}
});
- result.get(1, TimeUnit.MINUTES);
+ result.get(10, TimeUnit.MINUTES);
}
} catch (Exception e) {
