We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e89434d commit d0c1abdCopy full SHA for d0c1abd
1 file changed
paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala
@@ -43,10 +43,10 @@ case class PaimonPartitionReader(
43
) extends PartitionReader[InternalRow] {
44
45
private val splits: Iterator[Split] = partition.splits.toIterator
46
- @Nullable private var currentRecordReader = readSplit()
47
private var advanced = false
48
private var currentRow: PaimonInternalRow = _
49
private val ioManager: IOManager = createIOManager()
+ @Nullable private var currentRecordReader = readSplit()
50
private val sparkRow: SparkInternalRow = {
51
val dataFields = new JList(readBuilder.readType().getFields)
52
dataFields.addAll(metadataColumns.map(_.toPaimonDataField).asJava)
0 commit comments