You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by rb...@apache.org on 2020/05/13 22:23:24 UTC
[tez] branch master updated: TEZ-4174: [Kubernetes] Fetcher should
connection failure on SocketException (Prasanth Jayachandran reviewed by
Rajesh Balamohan)
This is an automated email from the ASF dual-hosted git repository.
rbalamohan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git
The following commit(s) were added to refs/heads/master by this push:
new 354c2a4 TEZ-4174: [Kubernetes] Fetcher should connection failure on SocketException (Prasanth Jayachandran reviewed by Rajesh Balamohan)
354c2a4 is described below
commit 354c2a4177fe8c3cf6b8a4c6009d4068a19d81f1
Author: Rajesh Balamohan <rb...@apache.org>
AuthorDate: Thu May 14 03:53:07 2020 +0530
TEZ-4174: [Kubernetes] Fetcher should connection failure on SocketException (Prasanth Jayachandran reviewed by Rajesh Balamohan)
---
.../java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java
index f9899f1..18f66cc 100644
--- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java
+++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java
@@ -547,7 +547,7 @@ public class Fetcher extends CallableWithNdc<FetchResult> {
"Fetch Failure while connecting from %s to: %s:%d, attempt: %s Informing ShuffleManager: ",
localHostname, host, port, firstAttempt), e);
return new HostFetchResult(new FetchResult(host, port, partition, partitionCount, srcAttemptsRemaining.values()),
- new InputAttemptIdentifier[] { firstAttempt }, false);
+ new InputAttemptIdentifier[] { firstAttempt }, true);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); //reset status