Minor

tdas · tdas · commit 8c603f46deb7 · 2016-12-15T19:24:27.000-08:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/EventTimeWatermarkSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/EventTimeWatermarkSuite.scala
@@ -53,13 +53,15 @@ class EventTimeWatermarkSuite extends StreamTest with BeforeAndAfter with Loggin
     assert(e.getMessage contains "int")
   }
 
-  test("error on threshold in months/years") {
+  test("error on delay in months/years") {
     val inputData = MemoryStream[Int].toDF()
 
     def check(delayThreshold: String): Unit = {
       val e = intercept[AnalysisException] {
         inputData.withWatermark("value", delayThreshold)
       }
+      assert(e.getMessage.contains("month"))
+      assert(e.getMessage.contains("year"))
     }
     check("1 year")
     check("2 months")

Original file line number	Diff line number	Diff line change
`@@ -53,13 +53,15 @@ class EventTimeWatermarkSuite extends StreamTest with BeforeAndAfter with Loggin`
`53`	`53`	`assert(e.getMessage contains "int")`
`54`	`54`	`}`
`55`	`55`
`56`		`- test("error on threshold in months/years") {`
	`56`	`+ test("error on delay in months/years") {`
`57`	`57`	`val inputData = MemoryStream[Int].toDF()`
`58`	`58`
`59`	`59`	`def check(delayThreshold: String): Unit = {`
`60`	`60`	`val e = intercept[AnalysisException] {`
`61`	`61`	`inputData.withWatermark("value", delayThreshold)`
`62`	`62`	`}`
	`63`	`+ assert(e.getMessage.contains("month"))`
	`64`	`+ assert(e.getMessage.contains("year"))`
`63`	`65`	`}`
`64`	`66`	`check("1 year")`
`65`	`67`	`check("2 months")`