diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala
index e9c52c9e8e471..b4813f7eb58b0 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala
@@ -239,7 +239,6 @@ object WALUtils {
     var output: BufferedOutputStream = null
     try {
       in = fm.open(sourceFile)
-      // in = decompressStream(fm.open(sourceFile), sparkConf)
       output = new BufferedOutputStream(new FileOutputStream(targetFile.toString))
       val buffer = new Array[Byte](1024)
       var eof = false