fix

JingsongLi · JingsongLi · commit 2f378e0e9533 · 2025-12-31T20:03:39.000+08:00
diff --git a/paimon-python/pypaimon/write/writer/data_writer.py b/paimon-python/pypaimon/write/writer/data_writer.py
@@ -191,7 +191,7 @@ def _write_data_to_file(self, data: pa.Table):
 
         key_column_stats = {
             field.name: self._get_column_stats(data, field.name)
-            for field in self.table.trimmed_primary_keys
+            for field in self.table.trimmed_primary_keys_fields
         }
         key_fields = self.trimmed_primary_keys_fields
         min_key_stats = [key_column_stats[field.name]['min_values'] for field in key_fields]

Original file line number	Diff line number	Diff line change
`@@ -191,7 +191,7 @@ def _write_data_to_file(self, data: pa.Table):`
`191`	`191`
`192`	`192`	`key_column_stats = {`
`193`	`193`	`field.name: self._get_column_stats(data, field.name)`
`194`		`- for field in self.table.trimmed_primary_keys`
	`194`	`+ for field in self.table.trimmed_primary_keys_fields`
`195`	`195`	`}`
`196`	`196`	`key_fields = self.trimmed_primary_keys_fields`
`197`	`197`	`min_key_stats = [key_column_stats[field.name]['min_values'] for field in key_fields]`