From 63e29368c17bec41ec7138e84013c3186f17ea98 Mon Sep 17 00:00:00 2001 From: yangjie01 Date: Fri, 16 Jan 2026 15:53:51 +0800 Subject: [PATCH] fix --- .../org/apache/paimon/spark/PaimonRecordReaderIterator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala index 16a05287ac8b..74f38ca66486 100644 --- a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala +++ b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala @@ -81,7 +81,7 @@ case class PaimonRecordReaderIterator( try { if (currentIterator != null) { currentIterator.releaseBatch() - currentResult == null + currentResult = null } } finally { reader.close()