From d4c2974eae98bde4ae21cd38c88e77227eb4b2c6 Mon Sep 17 00:00:00 2001 From: liujinhui <965147871@qq.com> Date: Fri, 13 Aug 2021 19:59:51 +0800 Subject: [PATCH] MINOR fix method use error (#3467) --- .../apache/hudi/examples/spark/HoodieWriteClientExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java b/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java index 257519b46..feddd1b9f 100644 --- a/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java +++ b/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java @@ -107,7 +107,7 @@ public class HoodieWriteClientExample { List> records = dataGen.generateInserts(newCommitTime, 10); List> recordsSoFar = new ArrayList<>(records); JavaRDD> writeRecords = jsc.parallelize(records, 1); - client.upsert(writeRecords, newCommitTime); + client.insert(writeRecords, newCommitTime); // updates newCommitTime = client.startCommit();