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 3dcc97c473b [bug](cloud) Use cached visible version when Fe replay
(#33054)
3dcc97c473b is described below
commit 3dcc97c473b521b694e137b2c87a36a854f91dd8
Author: xy720 <[email protected]>
AuthorDate: Sat Mar 30 11:28:17 2024 +0800
[bug](cloud) Use cached visible version when Fe replay (#33054)
---
.../src/main/java/org/apache/doris/binlog/AddPartitionRecord.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/catalog/Partition.java | 4 ++++
.../src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java | 5 +++++
3 files changed, 10 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java
b/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java
index 9bc5ff7da0f..cd872bec1bc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java
@@ -84,7 +84,7 @@ public class AddPartitionRecord {
sb.append(")");
}
sb.append("(\"version_info\" = \"");
- sb.append(partition.getVisibleVersion()).append("\"");
+ sb.append(partition.getCachedVisibleVersion()).append("\"");
sb.append(");");
this.sql = sb.toString();
}
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 1c9ec4e49a3..a41502e395f 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
@@ -161,6 +161,10 @@ public class Partition extends MetaObject implements
Writable {
this.setVisibleVersionAndTime(visibleVersion, visibleVersionTime);
}
+ public long getCachedVisibleVersion() {
+ return visibleVersion;
+ }
+
public long getVisibleVersion() {
return visibleVersion;
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
index 60e567ce9fe..8f72415e1de 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
@@ -100,6 +100,11 @@ public class CloudPartition extends Partition {
lock.unlock();
}
+ @Override
+ public long getCachedVisibleVersion() {
+ return super.getVisibleVersion();
+ }
+
@Override
public long getVisibleVersion() {
if (LOG.isDebugEnabled()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
