Skip to content
Permalink
Browse files
MINOR fix method use error (#3467)
  • Loading branch information
liujinhui1994 committed Aug 13, 2021
1 parent 6a4100b commit d4c2974eae98bde4ae21cd38c88e77227eb4b2c6
Showing 1 changed file with 1 addition and 1 deletion.
@@ -107,7 +107,7 @@ public static void main(String[] args) throws Exception {
List<HoodieRecord<HoodieAvroPayload>> records = dataGen.generateInserts(newCommitTime, 10);
List<HoodieRecord<HoodieAvroPayload>> recordsSoFar = new ArrayList<>(records);
JavaRDD<HoodieRecord<HoodieAvroPayload>> writeRecords = jsc.parallelize(records, 1);
client.upsert(writeRecords, newCommitTime);
client.insert(writeRecords, newCommitTime);

// updates
newCommitTime = client.startCommit();

0 comments on commit d4c2974

Please sign in to comment.