[tez] branch master updated: TEZ-4174: [Kubernetes] Fetcher should connection failure on SocketException (Prasanth Jayachandran reviewed by Rajesh Balamohan)

[rbalamohan]

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 <rbalamoh...@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