Skip to content

Conversation

@zhenlineo
Copy link
Contributor

@zhenlineo zhenlineo commented Mar 6, 2023

What changes were proposed in this pull request?

Add spark connect shell to start the spark shell with spark connect enabled.
Added "-Pconnect" to build the spark connect in the distributions.
Simplified the dev shell scripts with "-Pconnect" command.

Why are the changes needed?

Allow users to play with spark connect easily.

Does this PR introduce any user-facing change?

Yes. Added a new shell script and "-Pconnect" build option.

How was this patch tested?

Manually tested.

@zhenlineo zhenlineo changed the title [WIP] Spark Connect Shell [SPARK-42656][CONNECT][Followup] Spark Connect Shell Mar 6, 2023
@zhenlineo zhenlineo marked this pull request as ready for review March 6, 2023 22:49
@zhenlineo
Copy link
Contributor Author

If this PR accepted then no need to merge #40303 as this PR override the changes needed there.

Copy link
Contributor

@hvanhovell hvanhovell left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM - good stuff

@hvanhovell hvanhovell closed this in 2e7207f Mar 7, 2023
hvanhovell pushed a commit that referenced this pull request Mar 7, 2023
### What changes were proposed in this pull request?
Add spark connect shell to start the spark shell with spark connect enabled.
Added "-Pconnect" to build the spark connect in the distributions.
Simplified the dev shell scripts with "-Pconnect" command.

### Why are the changes needed?
Allow users to play with spark connect easily.

### Does this PR introduce _any_ user-facing change?
Yes. Added a new shell script and "-Pconnect" build option.

### How was this patch tested?
Manually tested.

Closes #40305 from zhenlineo/connect-shell.

Authored-by: Zhen Li <[email protected]>
Signed-off-by: Herman van Hovell <[email protected]>
(cherry picked from commit 2e7207f)
Signed-off-by: Herman van Hovell <[email protected]>
@hvanhovell
Copy link
Contributor

Merging.

sparkContext = sparkSession.sparkContext
sparkSession
} catch {
case e: ClassNotFoundException if isShellSession && e.getMessage.contains(
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#40318 I do a similar change for Scala 2.13

hvanhovell pushed a commit that referenced this pull request Mar 7, 2023
…Exception` catch to `repl.Main` for Scala 2.13

### What changes were proposed in this pull request?
This pr add the same `ClassNotFoundException` catch  to `repl.Main` for Scala 2.13 as #40305 due `org/apache/spark/repl/Main.scala` is Scala version sensitive。

### Why are the changes needed?
Make sure Scala 2.12 and 2.13 have the same logic

### Does this PR introduce _any_ user-facing change?
No

### How was this patch tested?
Manual check

Closes #40318 from LuciferYang/SPARK-42656-FOLLOWUP.

Authored-by: yangjie01 <[email protected]>
Signed-off-by: Herman van Hovell <[email protected]>
hvanhovell pushed a commit that referenced this pull request Mar 7, 2023
…Exception` catch to `repl.Main` for Scala 2.13

### What changes were proposed in this pull request?
This pr add the same `ClassNotFoundException` catch  to `repl.Main` for Scala 2.13 as #40305 due `org/apache/spark/repl/Main.scala` is Scala version sensitive。

### Why are the changes needed?
Make sure Scala 2.12 and 2.13 have the same logic

### Does this PR introduce _any_ user-facing change?
No

### How was this patch tested?
Manual check

Closes #40318 from LuciferYang/SPARK-42656-FOLLOWUP.

Authored-by: yangjie01 <[email protected]>
Signed-off-by: Herman van Hovell <[email protected]>
(cherry picked from commit 67328de)
Signed-off-by: Herman van Hovell <[email protected]>
Copy link
Member

@dongjoon-hyun dongjoon-hyun left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi, @zhenlineo and @hvanhovell . We need to register new profile as build_profile_flags.
Here is the PR.

snmvaughan pushed a commit to snmvaughan/spark that referenced this pull request Jun 20, 2023
### What changes were proposed in this pull request?
Add spark connect shell to start the spark shell with spark connect enabled.
Added "-Pconnect" to build the spark connect in the distributions.
Simplified the dev shell scripts with "-Pconnect" command.

### Why are the changes needed?
Allow users to play with spark connect easily.

### Does this PR introduce _any_ user-facing change?
Yes. Added a new shell script and "-Pconnect" build option.

### How was this patch tested?
Manually tested.

Closes apache#40305 from zhenlineo/connect-shell.

Authored-by: Zhen Li <[email protected]>
Signed-off-by: Herman van Hovell <[email protected]>
(cherry picked from commit 2e7207f)
Signed-off-by: Herman van Hovell <[email protected]>
snmvaughan pushed a commit to snmvaughan/spark that referenced this pull request Jun 20, 2023
…Exception` catch to `repl.Main` for Scala 2.13

### What changes were proposed in this pull request?
This pr add the same `ClassNotFoundException` catch  to `repl.Main` for Scala 2.13 as apache#40305 due `org/apache/spark/repl/Main.scala` is Scala version sensitive。

### Why are the changes needed?
Make sure Scala 2.12 and 2.13 have the same logic

### Does this PR introduce _any_ user-facing change?
No

### How was this patch tested?
Manual check

Closes apache#40318 from LuciferYang/SPARK-42656-FOLLOWUP.

Authored-by: yangjie01 <[email protected]>
Signed-off-by: Herman van Hovell <[email protected]>
(cherry picked from commit 67328de)
Signed-off-by: Herman van Hovell <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants