We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b36377f commit 14e209fCopy full SHA for 14e209f
paimon-python/pypaimon/read/table_read.py
@@ -224,8 +224,6 @@ def _create_split_read(self, split: Split) -> SplitRead:
224
elif self.table.options.data_evolution_enabled():
225
from pypaimon.globalindex.data_evolution_batch_scan import DataEvolutionBatchScan
226
predicate_for_read = DataEvolutionBatchScan.remove_row_id_filter(self.predicate)
227
- if predicate_for_read is None and self.predicate is not None:
228
- predicate_for_read = self.predicate
229
return DataEvolutionSplitRead(
230
table=self.table,
231
predicate=predicate_for_read,
0 commit comments