Kikyou1997 commented on code in PR #21849:
URL: https://github.com/apache/doris/pull/21849#discussion_r1267458911
##########
fe/fe-core/src/main/java/org/apache/doris/statistics/ColumnStatisticsCacheLoader.java:
##########
@@ -67,4 +82,43 @@ private Optional<ColumnStatistic> loadFromStatsTable(long
tableId, long idxId, S
return Optional.of(columnStatistics);
}
}
+
+ private void retryLoad(StatisticsCacheKey key) {
+
+ singleThreadPool.submit(new RetryTask(key, 1));
+ }
+
+ private static class RetryTask implements Runnable {
+ StatisticsCacheKey key;
+ int retryTimes;
+
+ public RetryTask(StatisticsCacheKey key, int retryTimes) {
+ this.key = key;
+ this.retryTimes = retryTimes;
+ }
+
+ @Override
+ public void run() {
+ List<ResultRow> columnResults = null;
+ try {
+ columnResults = StatisticsRepository.loadColStats(key.tableId,
key.idxId, key.colName);
+ } catch (InternalQueryExecutionException e) {
+ if (this.retryTimes < StatisticConstants.LOAD_RETRY_TIMES) {
Review Comment:
能用于做重试的资源是有限的，没法在持续执行失败的情况下还不停向BE发送请求
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
