Github user tdas commented on a diff in the pull request:

    https://github.com/apache/spark/pull/20096#discussion_r160009573
  
    --- Diff: 
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceOffset.scala
 ---
    @@ -19,7 +19,8 @@ package org.apache.spark.sql.kafka010
     
     import org.apache.kafka.common.TopicPartition
     
    -import org.apache.spark.sql.execution.streaming.{Offset, SerializedOffset}
    +import org.apache.spark.sql.execution.streaming.{Offset => OffsetV1, 
SerializedOffset}
    --- End diff --
    
    Ummm.. i think its better to rename new Offset to OffsetV2 than this rename 
old one to OffsetV1. This will keep it more consistent with other APIs which 
have V2 in them. Also, the MicroBatchExecution in the other PR also uses 
OffsetV2. Sorry for the nothing think ahead on this.


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to