Skip to content

Commit

Permalink
[#1254] fix(test): Fix the flaky test RssShuffleTest. (#1255)
Browse files Browse the repository at this point in the history
### What changes were proposed in this pull request?
As title.

### Why are the changes needed?

Fix: #1254 

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

unit test
  • Loading branch information
zhengchenyu authored and jerqi committed Oct 23, 2023
1 parent 8c196da commit cdb38ae
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -122,9 +122,9 @@ public void testKillSelf() throws IOException, InterruptedException {
conf.setLong(Constants.TEZ_RUNTIME_TASK_MEMORY, 300000L);
RssShuffle shuffle = new RssShuffle(inputContext, conf, 1, 3000000L, 0, APPATTEMPT_ID);
try {
shuffle.run();
ShuffleScheduler scheduler = shuffle.rssScheduler;
assertFalse(scheduler.isShutdown());
shuffle.run();

// killSelf() would invoke close(). Internally Shuffle --> merge.close() --> finalMerge()
// gets called. In MergeManager::finalMerge(), it would throw illegal argument exception
Expand Down

0 comments on commit cdb38ae

Please sign in to comment.