diff --git a/common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java b/common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java
index 1be32919c58..54598b7ef03 100644
--- a/common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java
+++ b/common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java
@@ -83,7 +83,7 @@ public ByteBuffer toByteBuffer() {
   public static TransportMessage fromByteBuffer(ByteBuffer buffer) throws CelebornIOException {
     int type = buffer.getInt();
     if (MessageType.forNumber(type) == null) {
-      throw new CelebornIOException("Decode failed,fallback to legacy messages.");
+      throw new CelebornIOException("Decode failed, fallback to legacy messages.");
     }
     int payloadLen = buffer.getInt();
     byte[] payload = new byte[payloadLen];