File tree Expand file tree Collapse file tree 2 files changed +5
-0
lines changed
Expand file tree Collapse file tree 2 files changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -1049,6 +1049,7 @@ def test_joins(started_cluster):
10491049 node = started_cluster .instances ["s0_0_0" ]
10501050
10511051 # Table join_table only exists on the node 's0_0_0'.
1052+ node .query ("DROP TABLE IF EXISTS join_table SYNC" )
10521053 node .query (
10531054 """
10541055 CREATE TABLE IF NOT EXISTS join_table (
Original file line number Diff line number Diff line change @@ -3446,6 +3446,10 @@ def execute_spark_query(query: str):
34463446
34473447 # Warm up metadata cache
34483448 for replica in started_cluster .instances .values ():
3449+ replica .query ("SYSTEM DROP UNCOMPRESSED CACHE" )
3450+ replica .query ("SYSTEM DROP QUERY CACHE" )
3451+ replica .query ("SYSTEM DROP FILESYSTEM CACHE" )
3452+ replica .query ("SYSTEM DROP ICEBERG METADATA CACHE" )
34493453 replica .query (f"SELECT * FROM { creation_expression } ORDER BY ALL SETTINGS allow_experimental_iceberg_read_optimization=0" )
34503454
34513455 all_data_expected_query_id = str (uuid .uuid4 ())
You can’t perform that action at this time.
0 commit comments