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