Add assert check

dhruve · dhruve · commit b3514067db43 · 2018-07-02T16:35:25.000-05:00
diff --git a/core/src/test/scala/org/apache/spark/input/WholeTextFileInputFormatSuite.scala b/core/src/test/scala/org/apache/spark/input/WholeTextFileInputFormatSuite.scala
@@ -70,8 +70,8 @@ class WholeTextFileInputFormatSuite extends SparkFunSuite with BeforeAndAfterAll
       WholeTextFileInputFormatSuite.files.foreach { case (filename, contents) =>
         createNativeFile(dir, filename, contents, false)
       }
-
-      val res = sc.wholeTextFiles(dir.toString).count
+      // ensure spark job runs successfully without exceptions from the CombineFileInputFormat
+      assert(sc.wholeTextFiles(dir.toString).count == 1)
     } finally {
       Utils.deleteRecursively(dir)
     }

Original file line number	Diff line number	Diff line change
`@@ -70,8 +70,8 @@ class WholeTextFileInputFormatSuite extends SparkFunSuite with BeforeAndAfterAll`
`70`	`70`	`WholeTextFileInputFormatSuite.files.foreach { case (filename, contents) =>`
`71`	`71`	`createNativeFile(dir, filename, contents, false)`
`72`	`72`	`}`
`73`		`-`
`74`		`- val res = sc.wholeTextFiles(dir.toString).count`
	`73`	`+ // ensure spark job runs successfully without exceptions from the CombineFileInputFormat`
	`74`	`+ assert(sc.wholeTextFiles(dir.toString).count == 1)`
`75`	`75`	`} finally {`
`76`	`76`	`Utils.deleteRecursively(dir)`
`77`	`77`	`}`