Commit 207e296
[SPARK-51789][CORE][FOLLOW-UP] Set the initial Spark Connect mode properly
### What changes were proposed in this pull request?
This PR is a followup of apache#50575 that sets the initial Spark Connect mode by reading `SPARK_CONNECT_MODE`.
### Why are the changes needed?
In Spark 4.0 release (Spark Connect distribution),
```bash
SPARK_CONNECT_MODE=1 ./bin/spark-shell
```
starts Spark Classic shells.
### Does this PR introduce _any_ user-facing change?
No to end users because the main change has not been released yet.
### How was this patch tested?
Manually tested with some combinations below:
```
SPARK_CONNECT_MODE=1 ./bin/spark-shell
SPARK_CONNECT_MODE=1 ./bin/spark-shell --master local
SPARK_CONNECT_MODE=1 ./bin/pyspark --conf spark.api.mode=classic --master local
SPARK_CONNECT_MODE=1 ./bin/pyspark --master local --conf spark.api.mode=connect
SPARK_CONNECT_MODE=1 ./bin/pyspark --conf spark.api.mode=classic
SPARK_CONNECT_MODE=1 ./bin/pyspark --conf spark.api.mode=connect
SPARK_CONNECT_MODE=1 ./bin/pyspark
SPARK_CONNECT_MODE=0 ./bin/spark-shell
SPARK_CONNECT_MODE=0 ./bin/spark-shell --master local
SPARK_CONNECT_MODE=0 ./bin/pyspark --conf spark.api.mode=classic --master local
SPARK_CONNECT_MODE=0 ./bin/pyspark --master local --conf spark.api.mode=connect
SPARK_CONNECT_MODE=0 ./bin/pyspark --conf spark.api.mode=classic
SPARK_CONNECT_MODE=0 ./bin/pyspark --conf spark.api.mode=connect
SPARK_CONNECT_MODE=0 ./bin/pyspark
SPARK_CONNECT_MODE=1 ./bin/spark-shell --master "local[*]" --remote "local[*]"
SPARK_CONNECT_MODE=1 ./bin/pyspark --conf spark.remote="local[*]" --conf spark.api.mode=connect --conf spark.master="local[*]"
SPARK_CONNECT_MODE=1 ./bin/pyspark --master "local[*]" --remote "local[*]"
SPARK_CONNECT_MODE=1 ./bin/pyspark --conf spark.remote="local[*]" --conf spark.api.mode=connect --master "local[*]"
```
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes apache#50846 from HyukjinKwon/SPARK-51789-followup.
Authored-by: Hyukjin Kwon <[email protected]>
Signed-off-by: Wenchen Fan <[email protected]>1 parent da2b449 commit 207e296
File tree
3 files changed
+9
-7
lines changed- launcher/src/main/java/org/apache/spark/launcher
- python/pyspark
- sql/connect
3 files changed
+9
-7
lines changedLines changed: 8 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
126 | 126 | | |
127 | 127 | | |
128 | 128 | | |
| 129 | + | |
129 | 130 | | |
130 | 131 | | |
131 | 132 | | |
| |||
549 | 550 | | |
550 | 551 | | |
551 | 552 | | |
552 | | - | |
553 | 553 | | |
554 | 554 | | |
555 | | - | |
556 | | - | |
| 555 | + | |
| 556 | + | |
| 557 | + | |
| 558 | + | |
| 559 | + | |
| 560 | + | |
| 561 | + | |
557 | 562 | | |
558 | 563 | | |
559 | 564 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
83 | 83 | | |
84 | 84 | | |
85 | 85 | | |
| 86 | + | |
86 | 87 | | |
87 | 88 | | |
88 | 89 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1074 | 1074 | | |
1075 | 1075 | | |
1076 | 1076 | | |
1077 | | - | |
1078 | 1077 | | |
1079 | 1078 | | |
1080 | 1079 | | |
1081 | 1080 | | |
1082 | 1081 | | |
1083 | | - | |
1084 | 1082 | | |
1085 | 1083 | | |
1086 | 1084 | | |
| |||
1098 | 1096 | | |
1099 | 1097 | | |
1100 | 1098 | | |
1101 | | - | |
1102 | | - | |
1103 | 1099 | | |
1104 | 1100 | | |
1105 | 1101 | | |
| |||
0 commit comments