gaoyajun02 opened a new pull request, #43004: URL: https://github.com/apache/spark/pull/43004
### What changes were proposed in this pull request? Add inflightMergedBlocks to avoid repeated fallback when failed to fetch remote push-merged block meta ### Why are the changes needed? When sendMergedBlockMetaReq is in flight, the channel happens to be closed, which will cause two `onFailure` callbacks, one from the responseHandler and the other from the listener of channelFuture. Two fallback will eventually cause the original block to be obtained twice. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? UT ### Was this patch authored or co-authored using generative AI tooling? No -- 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: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org
