From b95d2f811c34fd5bfbd6322e0fb06561c9ffce05 Mon Sep 17 00:00:00 2001
From: xupeng <xupeng@bytedance.com>
Date: Tue, 27 Jun 2017 11:53:46 +0800
Subject: [PATCH] modify client to retry connnect to datanode

---
 snakebite/client.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/snakebite/client.py b/snakebite/client.py
index 572b5f3..01788ce 100644
--- a/snakebite/client.py
+++ b/snakebite/client.py
@@ -19,7 +19,6 @@
 from snakebite.channel import DataXceiverChannel
 from snakebite.config import HDFSConfig
 from snakebite.errors import (
-    ConnectionFailureException,
     DirectoryException,
     FileAlreadyExistsException,
     FileException,
@@ -1162,10 +1161,11 @@ def _read_file(self, path, node, tail_only, check_crc, tail_length=1024):
                             failed_nodes.append(location.id.storageID)
                         successful_read = False
                 else:
-                    raise ConnectionFailureException(
+                    log.warning(
                         u"Failure to connect to data node at ({}:{})".format(
                             host, port
                             ))
+                    continue
                 if successful_read:
                     break
             if successful_read is False: