Github user koeninger commented on a diff in the pull request: https://github.com/apache/spark/pull/20572#discussion_r169536036 --- Diff: external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala --- @@ -22,12 +22,17 @@ import java.{ util => ju } import scala.collection.JavaConverters._ import scala.util.Random +import kafka.common.TopicAndPartition --- End diff -- Right, LogCleaner hadn't yet been moved to the new apis, added a comment to that effect. Think we're ok here because it's just being used to mock up a compacted topic, not in the actual dstream api.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org