diff --git a/common/network-common/src/main/java/org/apache/spark/network/crypto/GcmTransportCipher.java b/common/network-common/src/main/java/org/apache/spark/network/crypto/GcmTransportCipher.java index 6f9566662fd7d..d3f1bf490d3a3 100644 --- a/common/network-common/src/main/java/org/apache/spark/network/crypto/GcmTransportCipher.java +++ b/common/network-common/src/main/java/org/apache/spark/network/crypto/GcmTransportCipher.java @@ -383,7 +383,8 @@ public void channelRead(ChannelHandlerContext ctx, Object ciphertextMessage) int expectedRemaining = (int) (expectedLength - ciphertextRead); int bytesToRead = Integer.min(readableBytes, expectedRemaining); // The smallest ciphertext size is 16 bytes for the auth tag - ((Buffer) ciphertextBuffer).limit(((Buffer) ciphertextBuffer).position() + bytesToRead); + ((Buffer) ciphertextBuffer).limit( + ((Buffer) ciphertextBuffer).position() + bytesToRead); ciphertextNettyBuf.readBytes(ciphertextBuffer); ciphertextRead += bytesToRead; // Check if this is the last segment