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: