Update common/src/main/java/org/apache/celeborn/common/network/protoc…

…ol/TransportMessage.java Co-authored-by: Fu Chen <[email protected]>
apache · Jul 25, 2023 · 3716860 · 3716860
1 parent eab8537
commit 3716860
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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];