This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new dffde114570 [MINOR] Fix build on master (#11109)
dffde114570 is described below
commit dffde11457083d09ad3a595ad7535c6a02d95de9
Author: Y Ethan Guo <[email protected]>
AuthorDate: Fri Apr 26 17:40:06 2024 -0700
[MINOR] Fix build on master (#11109)
---
.../org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java | 2 +-
.../main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java
b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java
index 2b0fc2baa01..8b3b9202dfa 100644
---
a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java
+++
b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java
@@ -83,7 +83,7 @@ public class HoodieDeltaStreamerWrapper extends
HoodieDeltaStreamer {
StreamSync service = getDeltaSync();
service.refreshTimeline();
HoodieTableMetaClient metaClient = HoodieTableMetaClient.builder()
- .setConf((Configuration) service.getStorage().getConf().newCopy())
+ .setConf((Configuration) service.getStorage().getConf().unwrapCopy())
.setBasePath(service.getCfg().targetBasePath)
.build();
String instantTime = InProcessTimeGenerator.createNewInstantTime();
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java
index db01a1231f9..a5efe8c9693 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java
@@ -691,7 +691,7 @@ public class HoodieStreamer implements Serializable {
if (this.storage.exists(new StoragePath(cfg.targetBasePath))) {
try {
HoodieTableMetaClient meta = HoodieTableMetaClient.builder()
- .setConf((Configuration) this.storage.getConf().newCopy())
+ .setConf((Configuration) this.storage.getConf().unwrapCopy())
.setBasePath(cfg.targetBasePath).setLoadActiveTimelineOnLoad(false).build();
tableType = meta.getTableType();
// This will guarantee there is no surprise with table type