Fix test case.

Author: petermaxlee

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MetadataLog.scala

@@ -24,7 +24,7 @@ package org.apache.spark.sql.execution.streaming
  *  - Allow the user to query the latest batch id.
  *  - Allow the user to query the metadata object of a specified batch id.
  *  - Allow the user to query metadata objects in a range of batch ids.
- *  - Allow the user to remove obsolete metdata
+ *  - Allow the user to remove obsolete metadata
  */
 trait MetadataLog[T] {
 

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

@@ -125,7 +125,7 @@ class StreamingQuerySuite extends StreamTest with BeforeAndAfter {
     )
   }
 
-  testQuietly("StreamExecution metadata garbarge collection") {
+  testQuietly("StreamExecution metadata garbage collection") {
     val inputData = MemoryStream[Int]
     val mapped = inputData.toDS().map(6 / _)
 
@@ -139,15 +139,13 @@ class StreamingQuerySuite extends StreamTest with BeforeAndAfter {
       CheckAnswer(6, 3, 6, 3, 1, 1),
 
       // Three batches have run, but only one set of metadata should be present
-      AssertOnQuery(
-        q => {
-          val metadataLogDir = new java.io.File(q.offsetLog.metadataPath.toString)
-          val logFileNames = metadataLogDir.listFiles().toSeq.map(_.getName())
-          val toTest = logFileNames.filter(! _.endsWith(".crc")) // Workaround for SPARK-17475
-          toTest.size == 1 && toTest.head == "2"
-          true
-        }
-      )
+      AssertOnQuery("metadata log should contain only one file") { streamExecution =>
+        val metadataLogDir = new java.io.File(streamExecution.offsetLog.metadataPath.toString)
+        val logFileNames = metadataLogDir.listFiles().toSeq.map(_.getName())
+        val toTest = logFileNames.filter(!_.endsWith(".crc")) // Workaround for SPARK-17475
+        assert(toTest.size == 1 && toTest.head == "2")
+        true
+      }
     )
   }