This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new b612468ec8f branch-2.1: [fix](hudi) remove session variable field in
HudiScanNode #45762 (#45764)
b612468ec8f is described below
commit b612468ec8f3a45c00b0bd1a4cb68306d08c3eb2
Author: Mingyu Chen (Rayner) <morning...@163.com>
AuthorDate: Sun Dec 22 21:45:59 2024 +0800
branch-2.1: [fix](hudi) remove session variable field in HudiScanNode
#45762 (#45764)
cherry-pick #45762
---
.../org/apache/doris/datasource/hudi/source/HudiScanNode.java | 8 --------
1 file changed, 8 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java
index e1dfaa40aef..b1eb47095f3 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java
@@ -91,8 +91,6 @@ public class HudiScanNode extends HiveScanNode {
private final AtomicLong noLogsSplitNum = new AtomicLong(0);
- private final boolean useHiveSyncPartition;
-
private HoodieTableMetaClient hudiClient;
private String basePath;
private String inputFormat;
@@ -102,7 +100,6 @@ public class HudiScanNode extends HiveScanNode {
private boolean partitionInit = false;
private HoodieTimeline timeline;
- private Option<String> snapshotTimestamp;
private String queryInstant;
private final AtomicReference<UserException> batchException = new
AtomicReference<>(null);
@@ -113,7 +110,6 @@ public class HudiScanNode extends HiveScanNode {
private boolean incrementalRead = false;
private TableScanParams scanParams;
private IncrementalRelation incrementalRelation;
- private SessionVariable sessionVariable;
/**
* External file scan node for Query Hudi table
@@ -136,11 +132,9 @@ public class HudiScanNode extends HiveScanNode {
hmsTable.getFullQualifiers());
}
}
- useHiveSyncPartition = hmsTable.useHiveSyncPartition();
this.scanParams = scanParams.orElse(null);
this.incrementalRelation = incrementalRelation.orElse(null);
this.incrementalRead = (this.scanParams != null &&
this.scanParams.incrementalRead());
- this.sessionVariable = sessionVariable;
}
@Override
@@ -215,7 +209,6 @@ public class HudiScanNode extends HiveScanNode {
throw new UserException("Hudi does not support `FOR VERSION AS
OF`, please use `FOR TIME AS OF`");
}
queryInstant = tableSnapshot.getTime().replaceAll("[-: ]", "");
- snapshotTimestamp = Option.of(queryInstant);
} else {
Option<HoodieInstant> snapshotInstant = timeline.lastInstant();
if (!snapshotInstant.isPresent()) {
@@ -224,7 +217,6 @@ public class HudiScanNode extends HiveScanNode {
return;
}
queryInstant = snapshotInstant.get().getTimestamp();
- snapshotTimestamp = Option.empty();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
