File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -459,7 +459,7 @@ class CatalogSuite
459459 options = Map (" path" -> dir.getAbsolutePath))
460460 val table = spark.sessionState.catalog.getTableMetadata(TableIdentifier (" t" ))
461461 assert(table.tableType == CatalogTableType .EXTERNAL )
462- assert(table.storage.locationUri.get == dir.getAbsolutePath)
462+ assert(table.storage.locationUri.get == s " file: ${ dir.getAbsolutePath} " )
463463
464464 Seq ((1 )).toDF(" i" ).write.insertInto(" t" )
465465 assert(dir.exists() && dir.listFiles().nonEmpty)
Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ class PathOptionSuite extends DataSourceTest with SharedSQLContext {
7272 |USING ${classOf [TestOptionsSource ].getCanonicalName}
7373 |OPTIONS (PATH '/tmp/path')
7474 """ .stripMargin)
75- assert(getPathOption(" src" ) == Some (" /tmp/path" ))
75+ assert(getPathOption(" src" ) == Some (" file: /tmp/path" ))
7676 }
7777
7878 // should exist even path option is not specified when creating table
@@ -93,7 +93,7 @@ class PathOptionSuite extends DataSourceTest with SharedSQLContext {
9393 |OPTIONS (PATH ' $path')
9494 |AS SELECT 1
9595 """ .stripMargin)
96- assert(spark.table(" src" ).schema.head.metadata.getString(" path" ) == path)
96+ assert(spark.table(" src" ).schema.head.metadata.getString(" path" ) == s " file: $ path" )
9797 }
9898 }
9999
You can’t perform that action at this time.
0 commit comments