yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by 胡古飞
Commit e09a4c3132de73e608bde09ddc71519171ff32bf 1 parent ca4721a7

CommonBulkService队列大小改为500

Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
@@ -25,7 +25,7 @@ public class CommonBulkService implements ApplicationEventPublisherAware { @@ -25,7 +25,7 @@ public class CommonBulkService implements ApplicationEventPublisherAware {
25 25
26 private static final Logger logger = LoggerFactory.getLogger(CommonBulkService.class); 26 private static final Logger logger = LoggerFactory.getLogger(CommonBulkService.class);
27 27
28 - private final ArrayBlockingQueue<ESBluk> queue = new ArrayBlockingQueue<>(200); 28 + private final ArrayBlockingQueue<ESBluk> queue = new ArrayBlockingQueue<>(500);
29 29
30 @Autowired 30 @Autowired
31 private IYohoIndexService yohoIndexService; 31 private IYohoIndexService yohoIndexService;