Github user xuanyuanking commented on a diff in the pull request:
https://github.com/apache/spark/pull/20946#discussion_r183447988
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/OffsetSeqLogSuite.scala
---
@@ -125,6 +125,19 @@ class OffsetSeqLogSuite extends SparkFunSuite with
SharedSQLContext {
assert(offsetSeq.metadata === Some(OffsetSeqMetadata(0L,
1480981499528L)))
}
+ test("assertion that number of checkpoint offsets match number of
sources") {
--- End diff --
maybe no need add UT for the log change.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
