File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed
Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -68,11 +68,13 @@ struct SparkSessionTests {
6868 func closedSessionID( ) async throws {
6969 await SparkSession . builder. clear ( )
7070 let spark1 = try await SparkSession . builder. getOrCreate ( )
71- let sessionID = spark1. sessionID
72- await spark1. stop ( )
73- let remote = ProcessInfo . processInfo. environment [ " SPARK_REMOTE " ] ?? " sc://localhost "
74- try await #require( throws: Error . self) {
75- try await SparkSession . builder. remote ( " \( remote) /;session_id= \( sessionID) " ) . getOrCreate ( )
71+ if await spark1. version >= " 4.0.0 " {
72+ let sessionID = spark1. sessionID
73+ await spark1. stop ( )
74+ let remote = ProcessInfo . processInfo. environment [ " SPARK_REMOTE " ] ?? " sc://localhost "
75+ try await #require( throws: Error . self) {
76+ try await SparkSession . builder. remote ( " \( remote) /;session_id= \( sessionID) " ) . getOrCreate ( )
77+ }
7678 }
7779 }
7880
You can’t perform that action at this time.
0 commit comments