Skip to content

Commit

Permalink
Fix a test
Browse files Browse the repository at this point in the history
  • Loading branch information
yihua committed Sep 17, 2022
1 parent ed03513 commit d6d8480
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ public void testSuccessfulCompactionBasedOnNumAfterCompactionRequest() throws Ex

try (SparkRDDWriteClient<?> writeClient = getHoodieWriteClient(cfg)) {
List<HoodieRecord> records = dataGen.generateInserts(instants.get(0), 100);
HoodieReadClient readClient = getHoodieReadClient(cfg.getBasePath());
SparkRDDReadClient readClient = getHoodieReadClient(cfg.getBasePath());

// step 1: create and complete 4 delta commit, then create 1 compaction request after this
runNextDeltaCommits(writeClient, readClient, instants, records, cfg, true, new ArrayList<>());
Expand Down

0 comments on commit d6d8480

Please sign in to comment.