dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1099954380
##########
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java:
##########
@@ -116,9 +123,17 @@ public class HistoryServer {
private WebFrontendBootstrap netty;
private final long refreshIntervalMillis;
- private final ScheduledExecutorService executor =
+ private final ScheduledExecutorService fetcherExecutor =
Executors.newSingleThreadScheduledExecutor(
new
ExecutorThreadFactory("Flink-HistoryServer-ArchiveFetcher"));
+ private final ExecutorService unzipExecutor =
+ new ThreadPoolExecutor(
+ 8,
+ 32,
Review Comment:
I configure those thread number according to the frequency of
`HistoryServer` access
What do you suggest? Maybe I should parameterize those thread configurations
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
