This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 3336f14dcb [spark] Avoid serializing known splits in read builder
(#8050)
3336f14dcb is described below
commit 3336f14dcb5f6f6ab74578ecac21e27398fc6a4e
Author: Liurnly <[email protected]>
AuthorDate: Sun May 31 22:51:23 2026 +0800
[spark] Avoid serializing known splits in read builder (#8050)
---
.../src/main/java/org/apache/paimon/table/KnownSplitsTable.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/KnownSplitsTable.java
b/paimon-core/src/main/java/org/apache/paimon/table/KnownSplitsTable.java
index d76a6d700c..64b1952d1e 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/KnownSplitsTable.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/KnownSplitsTable.java
@@ -21,6 +21,7 @@ package org.apache.paimon.table;
import org.apache.paimon.fs.FileIO;
import org.apache.paimon.table.source.InnerTableRead;
import org.apache.paimon.table.source.InnerTableScan;
+import org.apache.paimon.table.source.ReadBuilder;
import org.apache.paimon.table.source.Split;
import org.apache.paimon.types.RowType;
@@ -48,6 +49,14 @@ public class KnownSplitsTable implements ReadonlyTable {
return splits;
}
+ @Override
+ public ReadBuilder newReadBuilder() {
+ // ReadonlyTable's default implementation creates
ReadBuilderImpl(this), which makes the
+ // ReadBuilder capture this KnownSplitsTable. ReadBuilder should not
carry all splits, so
+ // delegate to origin.
+ return origin.newReadBuilder();
+ }
+
@Override
public String name() {
return origin.name();