aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorStephane Gamard <stephane.gamard@sonarsource.com>2014-10-01 16:55:25 +0200
committerStephane Gamard <stephane.gamard@sonarsource.com>2014-10-01 16:55:25 +0200
commit3ca15a1d0624dc29b6442c49b4af8916164c09e5 (patch)
tree8343b47ea3b385a08dacb757d6bf402a3f7413b2
parent6d28e964b5c438c113dfce9e8461564a6dff2b00 (diff)
downloadsonarqube-3ca15a1d0624dc29b6442c49b4af8916164c09e5.tar.gz
sonarqube-3ca15a1d0624dc29b6442c49b4af8916164c09e5.zip
Increased timeout for denomarlization stack
-rw-r--r--server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java b/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java
index 3b6bd8d0cc5..4c0cdbbe625 100644
--- a/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java
+++ b/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java
@@ -56,7 +56,7 @@ public class IndexQueue implements ServerComponent, WorkQueue<IndexAction<?>> {
private static final Logger LOGGER = LoggerFactory.getLogger(IndexQueue.class);
- private static final Integer CONCURRENT_NORMALIZATION_FACTOR = 3;
+ private static final Integer CONCURRENT_NORMALIZATION_FACTOR = 1;
public IndexQueue(Settings settings, SearchClient searchClient, ComponentContainer container) {
this.searchClient = searchClient;
@@ -136,7 +136,7 @@ public class IndexQueue implements ServerComponent, WorkQueue<IndexAction<?>> {
boolean hasInlineRefreshRequest = false;
ExecutorService executorService = Executors.newFixedThreadPool(CONCURRENT_NORMALIZATION_FACTOR);
// invokeAll() blocks until ALL tasks submitted to executor complete
- List<Future<List<? extends ActionRequest>>> requests = executorService.invokeAll(actions, 20, TimeUnit.SECONDS);
+ List<Future<List<? extends ActionRequest>>> requests = executorService.invokeAll(actions, 20, TimeUnit.MINUTES);
for (Future<List<? extends ActionRequest>> updates : requests) {
for (ActionRequest update : updates.get()) {