fix: select count() result when read from s3 cluster

wxybear · wxybear · commit af7595932100 · 2025-05-05T18:05:41.000+02:00
diff --git a/tests/integration/test_storage_iceberg/test.py b/tests/integration/test_storage_iceberg/test.py
@@ -650,7 +650,8 @@ def add_df(mode):
         )
         assert len(cluster_secondary_queries) == 1
 
-    assert int(instance.query(f"SELECT count() FROM {table_function_expr_cluster}")) == 100
+    # write 3 times
+    assert int(instance.query(f"SELECT count() FROM {table_function_expr_cluster}")) == 100 * 3
 
 @pytest.mark.parametrize("format_version", ["1", "2"])
 @pytest.mark.parametrize("storage_type", ["s3", "azure", "local"])

Original file line number	Diff line number	Diff line change
`@@ -650,7 +650,8 @@ def add_df(mode):`
`650`	`650`	`)`
`651`	`651`	`assert len(cluster_secondary_queries) == 1`
`652`	`652`
`653`		`- assert int(instance.query(f"SELECT count() FROM {table_function_expr_cluster}")) == 100`
	`653`	`+ # write 3 times`
	`654`	`+ assert int(instance.query(f"SELECT count() FROM {table_function_expr_cluster}")) == 100 * 3`
`654`	`655`
`655`	`656`	`@pytest.mark.parametrize("format_version", ["1", "2"])`
`656`	`657`	`@pytest.mark.parametrize("storage_type", ["s3", "azure", "local"])`