diff --git a/common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java b/common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java
index 6652e99ef..dc1d8687f 100644
--- a/common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java
+++ b/common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java
@@ -63,6 +63,6 @@ public class ExceptionUtils {
   public static boolean connectFail(String message) {
     return (message.startsWith("Connection from ") && message.endsWith(" closed"))
         || (message.equals("Connection reset by peer"))
-        || (message.startsWith("Failed to send RPC "));
+        || (message.startsWith("Failed to send request "));
   }
 }