Fix unit test

apache · Dec 6, 2016 · 26a86d6 · 26a86d6
1 parent e3a7422
commit 26a86d6
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/OffsetSeqLogSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/OffsetSeqLogSuite.scala
@@ -77,8 +77,7 @@ class OffsetSeqLogSuite extends SparkFunSuite with SharedSQLContext {
       Some(SerializedOffset("0")),
       Some(SerializedOffset("""{"topic-0":{"0":1}}"""))
     ))
-    assert(offsetSeq.metadata ===
-      Some("""{"batchWatermarkMs":0,"batchTimestampMs":1480981499528}"""))
+    assert(offsetSeq.metadata === Some(OffsetSeqMetadata(0L, 1480981499528L)))
   }
 
   private def readFromResource(dir: String): (Long, OffsetSeq) = {