This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 5d8f4690f7 [Fix](autobucket) Fix autobucket partition size by using
getAllDataSize including cooldown size (#23557)
5d8f4690f7 is described below
commit 5d8f4690f756bf357493af06cb86c37c7ec3bdf5
Author: Jack Drogon <[email protected]>
AuthorDate: Mon Aug 28 15:24:48 2023 +0800
[Fix](autobucket) Fix autobucket partition size by using getAllDataSize
including cooldown size (#23557)
---
fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java | 5 +++++
.../main/java/org/apache/doris/clone/DynamicPartitionScheduler.java | 2 +-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java
index 6fad5e3fe3..53eb659735 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java
@@ -253,6 +253,11 @@ public class Partition extends MetaObject implements
Writable {
return indices;
}
+ public long getAllDataSize() {
+ return getDataSize() + getRemoteDataSize();
+ }
+
+ // this is local data size
public long getDataSize() {
long dataSize = 0;
for (MaterializedIndex mIndex :
getMaterializedIndices(IndexExtState.VISIBLE)) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
index a368e33a77..5641ff077d 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java
@@ -210,7 +210,7 @@ public class DynamicPartitionScheduler extends MasterDaemon
{
ArrayList<Long> partitionSizeArray = Lists.newArrayList();
for (Partition partition : partitions) {
if (partition.getVisibleVersion() >= 2) {
- partitionSizeArray.add(partition.getDataSize());
+ partitionSizeArray.add(partition.getAllDataSize());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
