We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 16f3ea0 commit 82b2ad2Copy full SHA for 82b2ad2
Sources/SparkConnect/SparkSession.swift
@@ -168,7 +168,7 @@ public actor SparkSession {
168
/// Create a new ``SparkSession``. If `spark.remote` is not given, `sc://localhost:15002` is used.
169
/// - Returns: A newly created `SparkSession`.
170
func create() async throws -> SparkSession {
171
- let session = SparkSession(sparkConf["spark.remote"] ?? "sc://localhost:15002")
+ let session = SparkSession(sparkConf["spark.remote"] ?? "sc://spark:15002")
172
let response = try await session.client.connect(session.sessionID)
173
await session.setVersion(response.sparkVersion.version)
174
let isSuccess = try await session.client.setConf(map: sparkConf)
0 commit comments