reduce for macos

dongjoon-hyun · dongjoon-hyun · commit e27ce9b95995 · 2025-04-23T17:36:21.000+09:00
diff --git a/Tests/SparkConnectTests/DataFrameTests.swift b/Tests/SparkConnectTests/DataFrameTests.swift
@@ -569,7 +569,7 @@ struct DataFrameTests {
     let spark = try await SparkSession.builder.getOrCreate()
     let tmpDir = "/tmp/" + UUID().uuidString
     let df = try await spark.range(2025)
-    for n in [1, 3, 5] as [Int32] {
+    for n in [1, 2, 3] as [Int32] {
       try await df.coalesce(n).write.mode("overwrite").orc(tmpDir)
       #expect(try await spark.read.orc(tmpDir).inputFiles().count == n)
     }

Original file line number	Diff line number	Diff line change
`@@ -569,7 +569,7 @@ struct DataFrameTests {`
`569`	`569`	`let spark = try await SparkSession.builder.getOrCreate()`
`570`	`570`	`let tmpDir = "/tmp/" + UUID().uuidString`
`571`	`571`	`let df = try await spark.range(2025)`
`572`		`- for n in [1, 3, 5] as [Int32] {`
	`572`	`+ for n in [1, 2, 3] as [Int32] {`
`573`	`573`	`try await df.coalesce(n).write.mode("overwrite").orc(tmpDir)`
`574`	`574`	`#expect(try await spark.read.orc(tmpDir).inputFiles().count == n)`
`575`	`575`	`}`