File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
client-spark/spark3/src/test/java/org/apache/spark/shuffle/writer Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -500,11 +500,11 @@ public void blockFailureResendTest() {
500500 assertEquals (2 , serverToPartitionToBlockIds .get (replacement ).get (0 ).size ());
501501
502502 // case2. If exceeding the max retry times, it will fast fail.
503- String taskId = "t2" ;
504503 FailedBlockSendTracker tracker = new FailedBlockSendTracker ();
505504 rssShuffleWriter .getReassignExecutor ().resetBlockSendTracker (tracker );
506505 bufferManagerSpy .resetRecordCount ();
507506 rssShuffleWriter .resetBlockFailSentRetryMaxTimes (1 );
507+ String taskId = "t2" ;
508508 rssShuffleWriter .setTaskId (taskId );
509509 rssShuffleWriter .getBufferManager ().setTaskId (taskId );
510510 taskToFailedBlockSendTracker .put (taskId , tracker );
You can’t perform that action at this time.
0 commit comments