diff --git a/hudi-examples/src/main/java/org/apache/hudi/examples/java/HoodieJavaWriteClientExample.java b/hudi-examples/src/main/java/org/apache/hudi/examples/java/HoodieJavaWriteClientExample.java index 4d06e4d15..587f73b0f 100644 --- a/hudi-examples/src/main/java/org/apache/hudi/examples/java/HoodieJavaWriteClientExample.java +++ b/hudi-examples/src/main/java/org/apache/hudi/examples/java/HoodieJavaWriteClientExample.java @@ -96,7 +96,7 @@ public class HoodieJavaWriteClientExample { List> recordsSoFar = new ArrayList<>(records); List> writeRecords = recordsSoFar.stream().map(r -> new HoodieRecord(r)).collect(Collectors.toList()); - client.upsert(writeRecords, newCommitTime); + client.insert(writeRecords, newCommitTime); // updates newCommitTime = client.startCommit();