diff options
author | Stephane Gamard <stephane.gamard@sonarsource.com> | 2014-10-01 16:55:25 +0200 |
---|---|---|
committer | Stephane Gamard <stephane.gamard@sonarsource.com> | 2014-10-01 16:55:25 +0200 |
commit | 3ca15a1d0624dc29b6442c49b4af8916164c09e5 (patch) | |
tree | 8343b47ea3b385a08dacb757d6bf402a3f7413b2 | |
parent | 6d28e964b5c438c113dfce9e8461564a6dff2b00 (diff) | |
download | sonarqube-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.java | 4 |
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()) { |