Skip to content

Commit b16471e

Browse files
committed
[SPARK-52059] Fix DataFrame to use SparkSession's transportSecurity
1 parent e3a440c commit b16471e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Sources/SparkConnect/DataFrame.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ public actor DataFrame: Sendable {
279279
try await withGRPCClient(
280280
transport: .http2NIOPosix(
281281
target: .dns(host: spark.client.host, port: spark.client.port),
282-
transportSecurity: .plaintext
282+
transportSecurity: spark.client.transportSecurity
283283
),
284284
interceptors: spark.client.getIntercepters()
285285
) { client in

0 commit comments

Comments
 (0)