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 15ec4fcdfd [python][ray] Fix flaky primary-key group writer test
(#10439)
15ec4fcdfd is described below
commit 15ec4fcdfd5fb61657d2de6df2c3eb30cff4f736
Author: XiaoHongbo <[email protected]>
AuthorDate: Thu Oct 8 20:42:45 2026 +0800
[python][ray] Fix flaky primary-key group writer test (#10439)
---
paimon-python/pypaimon/tests/ray_repartition_test.py | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/paimon-python/pypaimon/tests/ray_repartition_test.py
b/paimon-python/pypaimon/tests/ray_repartition_test.py
index 3b17784216..cc659e5106 100644
--- a/paimon-python/pypaimon/tests/ray_repartition_test.py
+++ b/paimon-python/pypaimon/tests/ray_repartition_test.py
@@ -610,7 +610,12 @@ class RayShuffleTest(unittest.TestCase):
result = self._read_table(identifier)
self.assertEqual(len(result), 1)
- self.assertTrue(result.iloc[0]['value'].startswith('0799-'))
+ # Ray's group-by shuffle does not preserve source row order inside a
+ # group. Without a sequence field, any of the duplicate-key input
+ # rows may therefore win; this test only requires one group writer.
+ self.assertIn(
+ result.iloc[0]['value'], rows.column('value').to_pylist()
+ )
# A subsequent writer must continue after the persisted sequence,
# including when native buffering removed the earlier duplicate rows.
