Skip to content

Commit e478df8

Browse files
committed
Set spark.driver.bindAddress and SPARK_LOCAL_IP
1 parent f30c57b commit e478df8

3 files changed

Lines changed: 3 additions & 0 deletions

File tree

.github/workflows/ci.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,7 @@ jobs:
269269

270270
- name: Integration Tests
271271
env:
272+
SPARK_LOCAL_IP: 127.0.0.1
272273
SPARK_HOME: ${{ steps.params.outputs.home }}/spark
273274
ARTIFACT_ID: ${{ steps.params.outputs.artifact-id }}
274275
VERSION: ${{ steps.params.outputs.version }}

python/test/spark_common.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ def get_spark_config(path, dependencies) -> SparkConf:
6464
master = 'local[2]'
6565
conf = SparkConf().setAppName('unit test').setMaster(master)
6666
return conf.setAll([
67+
('spark.driver.bindAddress', '127.0.0.1'),
6768
('spark.ui.showConsoleProgress', 'false'),
6869
('spark.test.home', os.environ.get('SPARK_HOME')),
6970
('spark.locality.wait', '0'),

src/test/scala/uk/co/gresearch/spark/SparkTestSession.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ trait SparkTestSession {
2727
.builder()
2828
.master(s"local[$cores]")
2929
.appName("spark test example")
30+
.config("spark.driver.bindAddress", "127.0.0.1")
3031
.config("spark.sql.shuffle.partitions", 2)
3132
.config("spark.local.dir", ".")
3233
.getOrCreate()

0 commit comments

Comments
 (0)