luoyuxia commented on code in PR #22805:
URL: https://github.com/apache/flink/pull/22805#discussion_r1231983326
##########
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/util/OrcFormatStatisticsReportUtil.java:
##########
@@ -58,11 +63,15 @@ public static TableStats getTableStatistics(
long rowCount = 0;
Map<String, ColumnStatistics> columnStatisticsMap = new
HashMap<>();
RowType producedRowType = (RowType)
producedDataType.getLogicalType();
+ ExecutorService executorService =
Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
Review Comment:
I'm wondering can we make it configurable but default is
`Runtime.getRuntime().availableProcessors()` just like some configuration
`s3.upload.max.concurrent.uploads`.
--
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]
