Skip to content

Commit 9c390fc

Browse files
committed
fix test_position_deletes_out_of_order
With the backport of 88827, prewhere for datalakes was explicitly disabled.
1 parent a2dcc74 commit 9c390fc

File tree

1 file changed

+3
-2
lines changed
  • tests/integration/test_storage_iceberg

1 file changed

+3
-2
lines changed

tests/integration/test_storage_iceberg/test.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -875,7 +875,8 @@ def test_position_deletes_out_of_order(started_cluster, use_roaring_bitmaps):
875875

876876
create_iceberg_table(storage_type, instance, TABLE_NAME, started_cluster, additional_settings=["input_format_parquet_use_native_reader_v3=1", f"use_roaring_bitmap_iceberg_positional_deletes={use_roaring_bitmaps}"])
877877

878-
assert get_array(instance.query(f"SELECT id FROM {TABLE_NAME} PREWHERE NOT sleepEachRow(1/100) order by id")) == list(range(10, 103)) + [104]
878+
# TODO: Replace WHERE with PREWHERE when we add prewhere support for datalakes.
879+
assert get_array(instance.query(f"SELECT id FROM {TABLE_NAME} WHERE NOT sleepEachRow(1/100) order by id")) == list(range(10, 103)) + [104]
879880

880881
instance.query(f"DROP TABLE {TABLE_NAME}")
881882

@@ -3922,7 +3923,7 @@ def check_validity_and_get_prunned_files(select_expression):
39223923
)
39233924

39243925

3925-
3926+
39263927
def test_iceberg_write_minmax(started_cluster):
39273928
instance = started_cluster.instances["node1"]
39283929
TABLE_NAME = "test_iceberg_write_minmax_" + get_uuid_str()

0 commit comments

Comments
 (0)