Skip to content

Commit 4f3fde2

Browse files
committed
Revert "[SPARK-27637][SHUFFLE][FOLLOW-UP] For nettyBlockTransferService, if IOException occurred while create client, check whether relative executor is alive before retry apache#24533"
This reverts commit 036fd39.
1 parent 8a8d39e commit 4f3fde2

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,8 +117,8 @@ private[spark] class NettyBlockTransferService(
117117
try {
118118
val blockFetchStarter = new RetryingBlockFetcher.BlockFetchStarter {
119119
override def createAndStart(blockIds: Array[String], listener: BlockFetchingListener) {
120+
val client = clientFactory.createClient(host, port)
120121
try {
121-
val client = clientFactory.createClient(host, port)
122122
new OneForOneBlockFetcher(client, appId, execId, blockIds, listener,
123123
transportConf, tempFileManager).start()
124124
} catch {

0 commit comments

Comments
 (0)