Skip to content

Commit dc2f57e

Browse files
committed
[SPARK-52059] Fix DataFrame to use SparkSession's transportSecurity
### What changes were proposed in this pull request? This PR aims to fix `DataFrame` to use `SparkSession`'s `transportSecurity`. ### Why are the changes needed? To support TLS correctly. This issue was reported during `v0.1.0 RC1` vote. ### Does this PR introduce _any_ user-facing change? Yes, but it's a bug fix which the previous behavior is not proper. ### How was this patch tested? Pass the CIs. ### Was this patch authored or co-authored using generative AI tooling? No. Closes #118 from dongjoon-hyun/SPARK-52059. Authored-by: Dongjoon Hyun <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
1 parent e3a440c commit dc2f57e

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)