import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import java.text.SimpleDateFormat;
import java.util.Collection;
LOG.debug("ise harvest failed", t);
storeOutcome(false, 0, t.getMessage());
}
- });
+ }, MoreExecutors.directExecutor());
try {
harvestResult.get(30, TimeUnit.SECONDS);