Skip to content

Commit

Permalink
decreasing indexation buffer size
Browse files Browse the repository at this point in the history
  • Loading branch information
Goulven.Furet authored and Goulven.Furet committed Dec 10, 2023
1 parent d6aebe3 commit e228b74
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ void enqueue(final DataFragment df) {
//TODO(conf) : elastinc bulk size from conf


if (fileQueue.size() > 400) {
if (fileQueue.size() > 200) {
aggregateAndstore();
}
}
Expand Down Expand Up @@ -189,7 +189,7 @@ public void aggregateAndstore() {
// There is data to consume and queue consummation is enabled
final Collection<DataFragment> buffer = fileQueue.values();


logger.error("Dequeuing {} datafragments", buffer.size());

// Retrieving datafragments
Map<String, Product> aggDatas = aggregatedDataRepository.multiGetById(
Expand Down

0 comments on commit e228b74

Please sign in to comment.