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 36e5ab41b00 branch-3.1: [fix](hudi) fix hudi p2 case #54948 (#54966)
36e5ab41b00 is described below
commit 36e5ab41b00a02904d9de9d39a521f7412f5aa04
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Aug 19 11:40:48 2025 +0800
branch-3.1: [fix](hudi) fix hudi p2 case #54948 (#54966)
Cherry-picked from #54948
Co-authored-by: Socrates <[email protected]>
---
.../org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
index 131b5195c7e..e0235e38661 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHudiScan.java
@@ -49,6 +49,7 @@ import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Collections;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
@@ -169,7 +170,8 @@ public class LogicalHudiScan extends LogicalFileScan {
Optional<IncrementalRelation> newIncrementalRelation =
Optional.empty();
if (optScanParams.isPresent() &&
optScanParams.get().incrementalRead()) {
TableScanParams scanParams = optScanParams.get();
- Map<String, String> optParams =
table.getBackendStorageProperties();
+ // Clone the getBackendStorageProperties, because we need to
modify it for the incremental read
+ Map<String, String> optParams = new
HashMap<>(table.getBackendStorageProperties());
if (scanParams.getMapParams().containsKey("beginTime")) {
optParams.put("hoodie.datasource.read.begin.instanttime",
scanParams.getMapParams().get("beginTime"));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
