Github user cloud-fan commented on a diff in the pull request: https://github.com/apache/spark/pull/20435#discussion_r165048049 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala --- @@ -403,7 +403,7 @@ class MicroBatchExecution( val current = committedOffsets.get(reader).map(off => reader.deserializeOffset(off.json)) reader.setOffsetRange( toJava(current), - Optional.of(available.asInstanceOf[OffsetV2])) + Optional.of(available.asInstanceOf[streaming.Offset])) --- End diff -- shall we still use `OffsetV2`?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org