diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
index d11482fb466..6cdbef87604 100644
--- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
+++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
@@ -281,7 +281,6 @@ class PushDataHandler(val workerSource: WorkerSource) extends BaseMessageHandler
         peer.getFetchPort,
         peer.getReplicatePort)
       if (unavailablePeers.containsKey(peerWorker)) {
-        // pushData.body().release()
         fileWriter.decrementPendingWrites()
         workerSource.incCounter(WorkerSource.REPLICATE_DATA_CREATE_CONNECTION_FAIL_COUNT)
         logError(