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 757626f commit c64bf20Copy full SHA for c64bf20
sql/core/src/test/scala/org/apache/spark/sql/execution/DataSourceScanExecRedactionSuite.scala
@@ -16,6 +16,8 @@
16
*/
17
package org.apache.spark.sql.execution
18
19
+import java.io.File
20
+
21
import scala.collection.mutable
22
23
import org.apache.hadoop.fs.Path
@@ -127,7 +129,7 @@ class DataSourceScanExecRedactionSuite extends DataSourceScanRedactionTest {
127
129
.write
128
130
.partitionBy(partitionCol)
131
.orc(dir)
- val paths = (0 to 9).map(i => s"$dir/$partitionCol=$i")
132
+ val paths = (0 to 9).map(i => new File(dir, s"$partitionCol=$i").getCanonicalPath)
133
val plan = spark.read.orc(paths: _*).queryExecution.executedPlan
134
val location = plan collectFirst {
135
case f: FileSourceScanExec => f.metadata("Location")
0 commit comments