File tree 1 file changed +5
-4
lines changed
interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/store
1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -68,7 +68,7 @@ public class StoreService implements MetricsAgent {
68
68
private ExecutorService writeExecutor ;
69
69
private ExecutorService ingestExecutor ;
70
70
private ExecutorService garbageCollectExecutor ;
71
- private ExecutorService downloadExecutor ;
71
+ private ThreadPoolExecutor downloadExecutor ;
72
72
private final boolean enableGc ;
73
73
private volatile boolean shouldStop = true ;
74
74
@@ -129,13 +129,14 @@ public void start() throws IOException {
129
129
logger .info ("StoreService started. storeId [" + this .storeId + "]" );
130
130
this .downloadExecutor =
131
131
new ThreadPoolExecutor (
132
- 0 ,
133
- 8 ,
134
- 0L ,
132
+ 16 ,
133
+ 16 ,
134
+ 1000L ,
135
135
TimeUnit .MILLISECONDS ,
136
136
new LinkedBlockingQueue <>(),
137
137
ThreadFactoryUtils .daemonThreadFactoryWithLogExceptionHandler (
138
138
"store-download" , logger ));
139
+ this .downloadExecutor .allowCoreThreadTimeOut (true );
139
140
logger .info ("StoreService started. storeId [" + this .storeId + "]" );
140
141
}
141
142
You can’t perform that action at this time.
0 commit comments