Skip to content

Commit 8464d71

Browse files
authored
Bump PySpark to 3.5.0 (#303)
1 parent 0f08806 commit 8464d71

File tree

5 files changed

+17
-43
lines changed

5 files changed

+17
-43
lines changed

poetry.lock

Lines changed: 9 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ requests-mock = "1.11.0"
8282
moto = { version = "^4.2.13", extras = ["server"] }
8383
typing-extensions = "4.9.0"
8484
pytest-mock = "3.12.0"
85-
pyspark = "3.4.2"
85+
pyspark = "3.5.0"
8686
cython = "3.0.8"
8787

8888
[[tool.mypy.overrides]]

tests/__init__.py

Lines changed: 0 additions & 16 deletions
This file was deleted.

tests/integration/__init__.py

Lines changed: 0 additions & 16 deletions
This file was deleted.

tests/integration/test_writes.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,10 +230,16 @@ def table_v1_v2_appended_with_null(session_catalog: Catalog, arrow_table_with_nu
230230

231231
@pytest.fixture(scope="session")
232232
def spark() -> SparkSession:
233+
import importlib.metadata
233234
import os
234235

236+
spark_version = ".".join(importlib.metadata.version("pyspark").split(".")[:2])
237+
scala_version = "2.12"
238+
iceberg_version = "1.4.3"
239+
235240
os.environ["PYSPARK_SUBMIT_ARGS"] = (
236-
"--packages org.apache.iceberg:iceberg-spark-runtime-3.4_2.12:1.4.0,org.apache.iceberg:iceberg-aws-bundle:1.4.0 pyspark-shell"
241+
f"--packages org.apache.iceberg:iceberg-spark-runtime-{spark_version}_{scala_version}:{iceberg_version},"
242+
f"org.apache.iceberg:iceberg-aws-bundle:{iceberg_version} pyspark-shell"
237243
)
238244
os.environ["AWS_REGION"] = "us-east-1"
239245
os.environ["AWS_ACCESS_KEY_ID"] = "admin"

0 commit comments

Comments
 (0)