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