This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 20e43480b00 branch-3.1: [fix](binlog) Avoid to issue getVersion RPC
during replay journals #57290 (#59256)
20e43480b00 is described below
commit 20e43480b0059b25228ff97226c15981c490cd1d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Dec 25 11:22:14 2025 +0800
branch-3.1: [fix](binlog) Avoid to issue getVersion RPC during replay
journals #57290 (#59256)
Cherry-picked from #57290
Co-authored-by: walter <[email protected]>
---
.../src/main/java/org/apache/doris/binlog/AddPartitionRecord.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 4ca3213ec12..a9e64b7fa88 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
@@ -86,7 +86,7 @@ public class AddPartitionRecord {
sb.append(", ");
sb.append(range.upperEndpoint().toSql());
sb.append(") (\"version_info\" = \"");
- sb.append(partition.getVisibleVersion());
+ sb.append(partition.getCachedVisibleVersion());
sb.append("\");");
} else if
(!this.listPartitionItem.equals(ListPartitionItem.DUMMY_ITEM)) {
// list
@@ -97,7 +97,7 @@ public class AddPartitionRecord {
sb.append(partitionSql);
}
sb.append(" (\"version_info\" = \"");
- sb.append(partition.getVisibleVersion());
+ sb.append(partition.getCachedVisibleVersion());
sb.append("\");");
} else {
// unpartitioned.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
