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 6a70d3c72e [python] Fix CI for unpartitioned split generation (#10169)
6a70d3c72e is described below

commit 6a70d3c72e604750192ef2df8b18ad8a7bb9c395
Author: Jingsong Lee <[email protected]>
AuthorDate: Fri Sep 25 08:51:46 2026 +0800

    [python] Fix CI for unpartitioned split generation (#10169)
---
 paimon-python/pypaimon/read/scanner/split_generator.py | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/paimon-python/pypaimon/read/scanner/split_generator.py 
b/paimon-python/pypaimon/read/scanner/split_generator.py
index ac0e15625f..c491fef39a 100644
--- a/paimon-python/pypaimon/read/scanner/split_generator.py
+++ b/paimon-python/pypaimon/read/scanner/split_generator.py
@@ -98,10 +98,12 @@ class AbstractSplitGenerator(ABC):
         if not packed_files or not file_entries:
             return splits
         partition = tuple(file_entries[0].partition.values)
-        path_factory = self.table.path_factory()
-        escaped_partition = (path_factory.bucket_path(
-            partition, file_entries[0].bucket, canonical_partition=True)
-            != path_factory.bucket_path(partition, file_entries[0].bucket))
+        escaped_partition = False
+        if partition:
+            path_factory = self.table.path_factory()
+            escaped_partition = (path_factory.bucket_path(
+                partition, file_entries[0].bucket, canonical_partition=True)
+                != path_factory.bucket_path(partition, file_entries[0].bucket))
         for file_group in packed_files:
             if use_optimized_path:
                 raw_convertible = True

Reply via email to