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