Fix test

petermaxlee · petermaxlee · commit 5e6113c941c3 · 2016-09-20T11:41:45.000-07:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala
@@ -142,7 +142,7 @@ class StreamingQuerySuite extends StreamTest with BeforeAndAfter {
       AssertOnQuery("metadata log should contain only one file") { q =>
         val metadataLogDir = new java.io.File(q.offsetLog.metadataPath.toString)
         val logFileNames = metadataLogDir.listFiles().toSeq.map(_.getName())
-        val toTest = logFileNames // Workaround for SPARK-17475
+        val toTest = logFileNames.filter(! _.endsWith(".crc"))  // Workaround for SPARK-17475
         assert(toTest.size == 1 && toTest.head == "2")
         true
       }

Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ class StreamingQuerySuite extends StreamTest with BeforeAndAfter {`
`142`	`142`	`AssertOnQuery("metadata log should contain only one file") { q =>`
`143`	`143`	`val metadataLogDir = new java.io.File(q.offsetLog.metadataPath.toString)`
`144`	`144`	`val logFileNames = metadataLogDir.listFiles().toSeq.map(_.getName())`
`145`		`- val toTest = logFileNames // Workaround for SPARK-17475`
	`145`	`+ val toTest = logFileNames.filter(! _.endsWith(".crc")) // Workaround for SPARK-17475`
`146`	`146`	`assert(toTest.size == 1 && toTest.head == "2")`
`147`	`147`	`true`
`148`	`148`	`}`