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();