This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 70612b7d1a7 [fix](cloud) cloud mode don't start collect partition info
thread (#36012)
70612b7d1a7 is described below
commit 70612b7d1a77a1db2c01a88046d3be41ed6ac13a
Author: yujun <[email protected]>
AuthorDate: Sat Jun 8 23:49:02 2024 +0800
[fix](cloud) cloud mode don't start collect partition info thread (#36012)
Collect partition info thread only use for sync info when be report
tablet, cloud mode no need to start it.
---
fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java | 4 ++--
.../src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java | 1 +
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
index f6db594d770..1a3077fc751 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
@@ -1726,6 +1726,8 @@ public class Env {
getConsistencyChecker().start();
// Backup handler
getBackupHandler().start();
+ // start daemon thread to update global partition version and in
memory information periodically
+ partitionInfoCollector.start();
}
jobManager.start();
// transient task manager
@@ -1752,8 +1754,6 @@ public class Env {
dynamicPartitionScheduler.start();
// start daemon thread to update db used data quota for db txn manager
periodically
dbUsedDataQuotaInfoCollector.start();
- // start daemon thread to update global partition in memory
information periodically
- partitionInfoCollector.start();
if (Config.enable_storage_policy) {
cooldownConfHandler.start();
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
index d5999b17ca3..06f96db2341 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
@@ -102,6 +102,7 @@ public class TabletInvertedIndex {
// partition id -> partition info.
// notice partition info update every
Config.partition_info_update_interval_secs seconds,
// so it may be stale.
+ // Notice only none-cloud use it for be reporting tablets. This map is
empty in cloud mode.
private volatile ImmutableMap<Long, PartitionCollectInfo>
partitionCollectInfoMap = ImmutableMap.of();
private ForkJoinPool taskPool = new
ForkJoinPool(Runtime.getRuntime().availableProcessors());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
