See <https://builds.apache.org/job/kafka-trunk-jdk8/2344/display/redirect?page=changes>
Changes: [wangguoz] MINOR: update docs with regard to improved resilience of Kafka Streams [wangguoz] MINOR: increase timeout for unstable [me] MINOR: Add async and different sync startup modes in connect service ------------------------------------------ [...truncated 135.76 KB...] <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:277: error writing class TestPurgatoryPerformance$CompletionQueue$Scheduled: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$CompletionQueue$Scheduled.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class Scheduled(val operation: FakeOperation) extends Delayed { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:185: error writing class TestPurgatoryPerformance$ExponentialDistribution: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$ExponentialDistribution.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class ExponentialDistribution(lambda: Double) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:240: error writing class TestPurgatoryPerformance$FakeOperation: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$FakeOperation.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class FakeOperation(delayMs: Long, size: Int, val latencyMs: Long, latch: CountDownLatch) extends DelayedOperation(delayMs) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:217: error writing class TestPurgatoryPerformance$IntervalSamples: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$IntervalSamples.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class IntervalSamples(sampleSize: Int, requestPerSecond: Double) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:222: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$IntervalSamples$$anonfun$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory (0 until sampleSize).map { _ => ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:235: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$IntervalSamples$$anonfun$printStats$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory .format(1000d / (samples.map(_.toDouble).sum / sampleSize.toDouble), samples.min, samples.max) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:196: error writing class TestPurgatoryPerformance$LatencySamples: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$LatencySamples.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class LatencySamples(sampleSize: Int, pct75: Double, pct50: Double) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:202: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$LatencySamples$$anonfun$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory (0 until sampleSize).map { _ => dist.next().toLong }.toArray ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala>:175: error writing class TestPurgatoryPerformance$LogNormalDistribution: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestPurgatoryPerformance$LogNormalDistribution.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory private class LogNormalDistribution(mu: Double, sigma: Double) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/other/kafka/TestTruncate.scala>:24: error writing object TestTruncate: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/TestTruncate.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory object TestTruncate { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:29: error writing class AclCommandTest: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory class AclCommandTest extends ZooKeeperTestHarness with Logging { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:79: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory Array[String]("--producer", "--consumer") -> ConsumerResourceToAcls.map { case (k, v) => k -> (v ++ ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:80: error writing <$anon: Function0>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$1$$anonfun$apply$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory ProducerResourceToAcls().getOrElse(k, Set.empty[Acl])) }, ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:81: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory Array[String]("--producer", "--idempotent", "--consumer") -> ConsumerResourceToAcls.map { case (k, v) => k -> (v ++ ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:82: error writing <$anon: Function0>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$2$$anonfun$apply$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory ProducerResourceToAcls(enableIdempotence = true).getOrElse(k, Set.empty[Acl])) } ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:67: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$kafka$admin$AclCommandTest$$ProducerResourceToAcls$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory if (enableIdempotence) Some(IdempotentWrite) else None).flatten, Hosts) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:150: error writing <$anon: Function2>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$kafka$admin$AclCommandTest$$getCmd$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory Users.foldLeft(cmd) ((cmd, user) => cmd ++ Array(principalCmd, user.toString)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:134: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$kafka$admin$AclCommandTest$$testRemove$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (resource <- resources) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:136: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$kafka$admin$AclCommandTest$$testRemove$1$$anonfun$apply$10.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory withAuthorizer(brokerProps) { authorizer => ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:91: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testAclCli$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((resources, resourceCmd) <- ResourceToCommand) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:91: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testAclCli$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((resources, resourceCmd) <- ResourceToCommand) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:92: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testAclCli$2$$anonfun$apply$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (permissionType <- PermissionType.values) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:96: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testAclCli$2$$anonfun$apply$3$$anonfun$apply$4.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (resource <- resources) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:97: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testAclCli$2$$anonfun$apply$3$$anonfun$apply$4$$anonfun$apply$5.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory withAuthorizer(brokerProps) { authorizer => ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:113: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((cmd, resourcesToAcls) <- CmdToResourcesToAcl) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:113: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((cmd, resourcesToAcls) <- CmdToResourcesToAcl) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:114: error writing <$anon: Function2>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2$$anonfun$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val resourceCommand: Array[String] = resourcesToAcls.keys.map(ResourceToCommand).foldLeft(Array[String]())(_ ++ _) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:116: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2$$anonfun$apply$6.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((resources, acls) <- resourcesToAcls) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:116: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2$$anonfun$apply$7.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for ((resources, acls) <- resourcesToAcls) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:117: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2$$anonfun$apply$7$$anonfun$apply$8.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (resource <- resources) { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala>:118: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AclCommandTest$$anonfun$testProducerConsumerCli$2$$anonfun$apply$7$$anonfun$apply$8$$anonfun$apply$9.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory withAuthorizer(brokerProps) { authorizer => ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:34: error writing class AddPartitionsTest: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory class AddPartitionsTest extends ZooKeeperTestHarness { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:112: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val metadata = ClientUtils.fetchTopicMetadata(Set(topic1), brokers.map(_.brokerEndPoint(listenerName)), ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:193: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$10.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val metaDataForTopic2 = metadata.find(p => p.topic == topic2).get ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:201: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$11.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val partitionOpt = metadata.partitionsMetadata.find(_.partitionId == partitionId) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:114: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val metaDataForTopic1 = metadata.filter(p => p.topic.equals(topic1)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:115: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val partitionDataForTopic1 = metaDataForTopic1.head.partitionsMetadata.sortBy(_.partitionId) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:141: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$4.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory brokers.map(_.brokerEndPoint(ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT))), ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:143: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$5.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val metaDataForTopic2 = metadata.filter(_.topic == topic2) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:144: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$6.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val partitionDataForTopic2 = metaDataForTopic2.head.partitionsMetadata.sortBy(_.partitionId) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:167: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$7.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory brokers.map(_.brokerEndPoint(ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT))), ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:170: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$8.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val metaDataForTopic3 = metadata.find(p => p.topic == topic3).get ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:190: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$9.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory brokers.map(_.brokerEndPoint(ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT))), ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:56: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$setUp$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory configs = (0 until 4).map(i => KafkaConfig.fromProps(TestUtils.createBrokerConfig(i, zkConnect, enableControlledShutdown = false))) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:58: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$setUp$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory servers = configs.map(c => TestUtils.createServer(c)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:59: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$setUp$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory brokers = servers.map(s => TestUtils.createBroker(s.config.brokerId, s.config.hostName, TestUtils.boundPort(s))) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala>:208: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AddPartitionsTest$$anonfun$validateLeaderAndReplicas$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals("Replica set should match", expectedReplicas, partition.replicas.map(_.id).toSet) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:25: error writing class AdminRackAwareTest: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory class AdminRackAwareTest extends RackAwareTest with Logging { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:162: error writing <$anon: Function0>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testLessReplicasThanRacks$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:164: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testLessReplicasThanRacks$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (partition <- 0 to 5) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:162: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testLessReplicasThanRacks$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:149: error writing <$anon: Function0>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testMoreReplicasThanRacks$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:151: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testMoreReplicasThanRacks$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (partition <- 0 until numPartitions) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:149: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testMoreReplicasThanRacks$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:174: error writing <$anon: Function0>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testSingleRack$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:176: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testSingleRack$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (partition <- 0 until numPartitions) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:178: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testSingleRack$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory for (broker <- brokerRackMapping.keys) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:174: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testSingleRack$4.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(List.fill(assignment.size)(replicationFactor), assignment.values.map(_.size)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala>:189: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminRackAwareTest$$anonfun$testSkipBrokerWithReplicaAlreadyAssigned$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory assertEquals(brokerList, brokerMetadatas.map(_.id)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:46: error writing class AdminTest: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory class AdminTest extends ZooKeeperTestHarness with Logging with RackAwareTest { ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:58: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$1.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val brokerMetadatas = (0 to 4).map(new BrokerMetadata(_, None)) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:146: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$2.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val actualReplicaList = leaderForPartitionMap.keys.toArray.map(p => p -> zkUtils.getReplicasForPartition(topic, p)).toMap ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:344: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$3.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val serverConfigs = TestUtils.createBrokerConfigs(3, zkConnect, false, rackInfo = brokerRack).map(KafkaConfig.fromProps) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:363: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$4.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val serverConfigs = TestUtils.createBrokerConfigs(3, zkConnect, false).map(KafkaConfig.fromProps) ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:369: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$5.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val controller = servers.find(p => p.config.brokerId == controllerId).get.kafkaController ^ <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/src/test/scala/unit/kafka/admin/AdminTest.scala>:371: error writing <$anon: Function1>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka/admin/AdminTest$$anonfun$6.class>: <https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/classes/scala/test/kafka> is not a directory val controlledShutdownCallback = (controlledShutdownResult: Try[Set[TopicPartition]]) => resultQueue.put(controlledShutdownResult) ^ 202 warnings found 3827 errors found :kafka-trunk-jdk8:core:compileTestScala FAILED :test_core_2_11 FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':kafka-trunk-jdk8:core:compileTestScala'. > Compilation failed * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org BUILD FAILED in 2m 24s 16 actionable tasks: 3 executed, 13 up-to-date FAILURE: Build failed with an exception. * What went wrong: Could not add entry ':core:compileTestScala' to cache taskHistory.bin (<https://builds.apache.org/job/kafka-trunk-jdk8/ws/.gradle/4.4.1/taskHistory/taskHistory.bin).> > java.io.IOException: No space left on device * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org BUILD FAILED in 2m 25s Build step 'Execute shell' marked build as failure [FINDBUGS] Collecting findbugs analysis files... ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-trunk-jdk8/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] No files found. Configuration error? ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 <Git Blamer> Using GitBlamer to create author and commit information for all warnings. <Git Blamer> GIT_COMMIT=83cc138e0c04a2f30f4536c27314890d06818190, workspace=<https://builds.apache.org/job/kafka-trunk-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #2342 Recording test results ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: Step ‘Publish JUnit test result report’ failed: No test report files were found. Configuration error? ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Not sending mail to unregistered user [email protected]
