Skip to content

Commit 2573480

Browse files
author
Steven Wu
committed
change default jobQueueSize from 1,000 to 100
1 parent 02a86ae commit 2573480

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

suro-core/src/main/java/com/netflix/suro/sink/ThreadPoolQueuedSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public ThreadPoolQueuedSink(
2424
int maxPoolSize,
2525
long jobTimeout,
2626
String threadFactoryName) {
27-
jobQueue = new ArrayBlockingQueue<Runnable>(jobQueueSize == 0 ? 1000 : jobQueueSize) {
27+
jobQueue = new ArrayBlockingQueue<Runnable>(jobQueueSize == 0 ? 100 : jobQueueSize) {
2828
@Override
2929
public boolean offer(Runnable runnable) {
3030
try {

0 commit comments

Comments
 (0)