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: [email protected]
For additional commands, e-mail: [email protected]
