Address comment.

apache · Feb 17, 2018 · 8bd02d8 · 8bd02d8
1 parent e08d06c
commit 8bd02d8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala b/...src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala
@@ -399,7 +399,7 @@ class ParquetFileFormat
         val vectorizedReader = new VectorizedParquetRecordReader(
           convertTz.orNull, enableOffHeapColumnVector && taskContext.isDefined, capacity)
         val iter = new RecordReaderIterator(vectorizedReader)
-        // Register a task completion lister before `initialization`.
+        // SPARK-23457 Register a task completion lister before `initialization`.
         taskContext.foreach(_.addTaskCompletionListener(_ => iter.close()))
         vectorizedReader.initialize(split, hadoopAttemptContext)
         logDebug(s"Appending $partitionSchema ${file.partitionValues}")
@@ -420,7 +420,7 @@ class ParquetFileFormat
           new ParquetRecordReader[UnsafeRow](new ParquetReadSupport(convertTz))
         }
         val iter = new RecordReaderIterator(reader)
-        // Register a task completion lister before `initialization`.
+        // SPARK-23457 Register a task completion lister before `initialization`.
         taskContext.foreach(_.addTaskCompletionListener(_ => iter.close()))
         reader.initialize(split, hadoopAttemptContext)