tedyu opened a new pull request, #39611:
URL: https://github.com/apache/spark/pull/39611

   ### What changes were proposed in this pull request?
   This PR introduces sasl retry count in RetryingBlockTransferor.
   
   ### Why are the changes needed?
   Previously a boolean variable, saslTimeoutSeen, was used. However, the 
boolean variable wouldn't cover the following scenario:
   
   1. SaslTimeoutException
   2. IOException
   3. SaslTimeoutException
   4. IOException
   
   Even though IOException at #2 is retried (resulting in increment of 
retryCount), the retryCount would be cleared at step #4.
   Since the intention of saslTimeoutSeen is to undo the increment due to 
retrying SaslTimeoutException, we should keep a counter for 
SaslTimeoutException retries and subtract the value of this counter from 
retryCount.
   
   ### Does this PR introduce _any_ user-facing change?
   No
   
   ### How was this patch tested?
   New test is added, courtesy of Mridul.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to