File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
sql/core/src/test/scala/org/apache/spark/sql/streaming Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -210,8 +210,9 @@ class FileStreamSourceSuite extends FileStreamSourceTest with SharedSQLContext {
210210
211211 test(" FileStreamSource schema: parquet, existing files, no schema" ) {
212212 withTempDir { src =>
213- Seq (" a" , " b" , " c" ).toDS().as(" userColumn" ).toDF()
214- .write.parquet(new File (src, " 1" ).getCanonicalPath)
213+ Seq (" a" , " b" , " c" ).toDS().as(" userColumn" ).toDF().write
214+ .mode(org.apache.spark.sql.SaveMode .Overwrite )
215+ .parquet(src.getCanonicalPath)
215216 val schema = createFileStreamSourceAndGetSchema(
216217 format = Some (" parquet" ), path = Some (src.getCanonicalPath), schema = None )
217218 assert(schema === new StructType ().add(" value" , StringType ))
You can’t perform that action at this time.
0 commit comments