Disable lateralJoin

dongjoon-hyun · dongjoon-hyun · commit 1c1e19d921c4 · 2025-05-06T15:43:04.000-07:00
diff --git a/Tests/SparkConnectTests/DataFrameTests.swift b/Tests/SparkConnectTests/DataFrameTests.swift
@@ -504,7 +504,7 @@ struct DataFrameTests {
     #expect(try await df1.join(df2, joinExprs: "T.b = S.b", joinType: "inner").collect() == expected)
     await spark.stop()
   }
-
+#if !os(Linux) TODO: Enable this on linux
   @Test
   func lateralJoin() async throws {
     let spark = try await SparkSession.builder.getOrCreate()
@@ -526,7 +526,7 @@ struct DataFrameTests {
     }
     await spark.stop()
   }
-
+#endif
   @Test
   func except() async throws {
     let spark = try await SparkSession.builder.getOrCreate()

Original file line number	Diff line number	Diff line change
`@@ -504,7 +504,7 @@ struct DataFrameTests {`
`504`	`504`	`#expect(try await df1.join(df2, joinExprs: "T.b = S.b", joinType: "inner").collect() == expected)`
`505`	`505`	`await spark.stop()`
`506`	`506`	`}`
`507`		`-`
	`507`	`+#if !os(Linux) TODO: Enable this on linux`
`508`	`508`	`@Test`
`509`	`509`	`func lateralJoin() async throws {`
`510`	`510`	`let spark = try await SparkSession.builder.getOrCreate()`
`@@ -526,7 +526,7 @@ struct DataFrameTests {`
`526`	`526`	`}`
`527`	`527`	`await spark.stop()`
`528`	`528`	`}`
`529`		`-`
	`529`	`+#endif`
`530`	`530`	`@Test`
`531`	`531`	`func except() async throws {`
`532`	`532`	`let spark = try await SparkSession.builder.getOrCreate()`