update: comment in code

apache · Sep 30, 2022 · be8c12e · be8c12e
1 parent 573c27a
commit be8c12e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala b/...-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala
@@ -515,6 +515,8 @@ class HoodieCDCRDD(
         val iter = loadFileSlice(fileSlice)
         iter.foreach { row =>
           val key = getRecordKey(row)
+          // Due to the reuse buffer mechanism of Spark serialization,
+          // we have to copy the serialized result if we need to retain its reference
           beforeImageRecords.put(key, serialize(row, copy = true))
         }
         // reset beforeImageFiles