Skip to content

Commit bddaa64

Browse files
committed
[SPARK-19137][SQL][SS] Garbage left in source tree after SQL tests are run
1 parent 15c2bd0 commit bddaa64

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/streaming/test/DataStreamReaderWriterSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -601,9 +601,11 @@ class DataStreamReaderWriterSuite extends StreamTest with BeforeAndAfter with Pr
601601
StructField("part", IntegerType), // inferred partitionColumn dataType
602602
StructField("id", StringType))) // used user provided partitionColumn dataType
603603

604+
val checkpointLoc = newMetadataDir
604605
val sq = sdf.writeStream
605606
.queryName("corruption_test")
606607
.format("memory")
608+
.option("checkpointLocation", checkpointLoc)
607609
.start()
608610
sq.processAllAvailable()
609611
checkAnswer(

0 commit comments

Comments
 (0)