Add connection timed out to list of failures for uncaught Excep Handler

giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java

@@ -1193,8 +1193,12 @@ public boolean checkIfWorkerShouldFail(Thread thread, Throwable exception) {
    * @return True if the throwable is a "connection reset by peer",
    * false otherwise.
    */
-  public static boolean isConnectionResetByPeer(Throwable throwable) {
-    return throwable.getMessage().startsWith(
-      "Connection reset by peer") ? true : false;
+  public static boolean isConnectionFailure(Throwable throwable) {
+    String throwableMessage = throwable.getMessage().toLowerCase();
+    if (throwableMessage.startsWith("connection reset by peer") ||
+      throwableMessage.startsWith("connection timed out")) {
+      return true;
+    }
+    return false;
   }
 }

giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java

@@ -121,7 +121,7 @@
 
 import com.google.common.collect.Lists;
 
-import static org.apache.giraph.graph.GraphTaskManager.isConnectionResetByPeer;
+import static org.apache.giraph.graph.GraphTaskManager.isConnectionFailure;
 
 /**
  * ZooKeeper-based implementation of {@link CentralizedServiceWorker}.
@@ -224,7 +224,7 @@ public BspServiceWorker(
             // If the connection was closed by the client, then we just log
             // the error, we do not fail the job, since the client will
             // attempt to reconnect.
-            return !isConnectionResetByPeer(throwable);
+            return !isConnectionFailure(throwable);
           }
         )
     );