Github user ijuma commented on the issue: https://github.com/apache/spark/pull/21955 Looks like some test code is using internal Kafka classes that have changed or have been removed: > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockTime.scala:22: object Time is not a member of package kafka.utils > [error] import kafka.utils.Time > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockTime.scala:33: not found: type Time > [error] private[kafka010] class MockTime(@volatile private var currentMs: Long) extends Time { > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:83: not enough arguments for constructor Log: (dir: java.io.File, config: kafka.log.LogConfig, logStartOffset: Long, recoveryPoint: Long, scheduler: kafka.utils.Scheduler, brokerTopicStats: kafka.server.BrokerTopicStats, time: org.apache.kafka.common.utils.Time, maxProducerIdExpirationMs: Int, producerIdExpirationCheckIntervalMs: Int, topicPartition: org.apache.kafka.common.TopicPartition, producerStateManager: kafka.log.ProducerStateManager, logDirFailureChannel: kafka.server.LogDirFailureChannel)kafka.log.Log. > [error] Unspecified value parameters brokerTopicStats, time, maxProducerIdExpirationMs... > [error] val log = new Log( > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:91: not found: type ByteBufferMessageSet > [error] val msg = new ByteBufferMessageSet( > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:93: not found: type Message > [error] new Message(v.getBytes, k.getBytes, Message.NoTimestamp, Message.CurrentMagicValue)) > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:93: not found: value Message > [error] new Message(v.getBytes, k.getBytes, Message.NoTimestamp, Message.CurrentMagicValue)) > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:93: not found: value Message > [error] new Message(v.getBytes, k.getBytes, Message.NoTimestamp, Message.CurrentMagicValue)) > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala:99: not enough arguments for constructor LogCleaner: (initialConfig: kafka.log.CleanerConfig, logDirs: Seq[java.io.File], logs: kafka.utils.Pool[org.apache.kafka.common.TopicPartition,kafka.log.Log], logDirFailureChannel: kafka.server.LogDirFailureChannel, time: org.apache.kafka.common.utils.Time)kafka.log.LogCleaner. > [error] Unspecified value parameter logDirFailureChannel. > [error] val cleaner = new LogCleaner(CleanerConfig(), logDirs = Array(dir), logs = logs) > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockScheduler.scala:24: object Time is not a member of package kafka.utils > [error] import kafka.utils.{Scheduler, Time} > [error] ^ > [error] /home/jenkins/workspace/SparkPullRequestBuilder/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockScheduler.scala:41: not found: type Time > [error] private[kafka010] class MockScheduler(val time: Time) extends Scheduler { > [error] ^
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org