See
<https://builds.apache.org/job/kafka-trunk-jdk7/3416/display/redirect?page=changes>
Changes:
[rajinisivaram] KAFKA-6870 Concurrency conflicts in SampledStat (#4985)
------------------------------------------
[...truncated 64.07 KB...]
withAuthorizer(opts) { authorizer =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:124:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$kafka$admin$AclCommand$$listAcl$1$$anonfun$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
else resources.map(resource => resource -> authorizer.getAcls(resource))
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:126:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$kafka$admin$AclCommand$$listAcl$1$$anonfun$apply$8.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcls)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:126:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$kafka$admin$AclCommand$$listAcl$1$$anonfun$apply$9.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcls)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:127:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$kafka$admin$AclCommand$$listAcl$1$$anonfun$apply$9$$anonfun$apply$10.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
println(s"Current ACLs for resource `$resource`: $Newline
${acls.map("\t" + _).mkString(Newline)} $Newline")
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:101:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$removeAcl$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
withAuthorizer(opts) { authorizer =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:104:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$removeAcl$1$$anonfun$apply$5.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcl) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:104:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$removeAcl$1$$anonfun$apply$6.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcl) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:109:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$removeAcl$1$$anonfun$apply$6$$anonfun$apply$7.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
if (confirmAction(opts, s"Are you sure you want to remove ACLs:
$Newline ${acls.map("\t" + _).mkString(Newline)} $Newline from resource
`$resource`? (y/n)"))
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:267:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$validateOperation$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcls) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:267:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$validateOperation$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
for ((resource, acls) <- resourceToAcls) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:269:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$validateOperation$2$$anonfun$apply$14.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
if ((acls.map(_.operation) -- validOps).nonEmpty)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:81:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$$anonfun$withAuthorizer$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
finally CoreUtils.swallow(authZ.close(), this)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:274:
error writing class AclCommand$AclCommandOptions:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$AclCommandOptions.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
class AclCommandOptions(args: Array[String]) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:322:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$AclCommandOptions$$anonfun$7.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
Operation.values.map("\t" + _).mkString(Newline) + Newline)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AclCommand.scala>:372:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AclCommand$AclCommandOptions$$anonfun$8.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val actions = Seq(addOpt, removeOpt, listOpt).count(options.has)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:435:
error writing object AdminClient:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
object AdminClient {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:49:
error writing class AdminClient:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
class AdminClient(val time: Time,
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:58:
error writing <$anon: Runnable>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anon$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val networkThread = new KafkaThread("admin-client-network-thread", new
Runnable {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:65:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anon$1$$anonfun$run$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
error("admin-client-network-thread exited", t)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:65:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anon$1$$anonfun$run$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
error("admin-client-network-thread exited", t)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:67:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anon$1$$anonfun$run$3.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
pendingFutures.asScala.foreach { future =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:236:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val metadataRequest = new
MetadataRequest.Builder(offsets.keys.map(_.topic).toSet.toList.asJava, true)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:280:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$11.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val defaultResults = offsets.mapValues(_ =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:330:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$12.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val consumers = metadata.members.asScala.map { consumer =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:242:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val (partitionsWithoutError, partitionsWithError) = offsets.partition{
partitionAndOffset =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:245:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$3.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val (partitionsWithLeader, partitionsWithoutLeader) =
partitionsWithoutError.partition{ partitionAndOffset =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:248:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$4.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val partitionsWithErrorResults = partitionsWithError.keys.map( partition =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:251:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$5.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val partitionsWithoutLeaderResults = partitionsWithoutLeader.mapValues( _ =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:254:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$6.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val partitionsGroupByLeader =
partitionsWithLeader.groupBy(partitionAndOffset =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:258:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$7.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val futures = partitionsGroupByLeader.map{ case (node, partitionAndOffsets)
=>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:262:
error writing <$anon:
org.apache.kafka.clients.consumer.internals.RequestFutureAdapter>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$7$$anon$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
future.compose(new RequestFutureAdapter[ClientResponse,
Map[TopicPartition, DeleteRecordsResult]]() {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:271:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$7$$anon$2$$anonfun$10.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val result = partitionAndOffsets.mapValues(_ =>
DeleteRecordsResult(DeleteRecordsResponse.INVALID_LOW_WATERMARK, e))
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:265:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$7$$anon$2$$anonfun$9.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val result = deleteRecordsResponse.responses().asScala.mapValues(v
=> DeleteRecordsResult(v.lowWatermark, v.error.exception())).toMap
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:259:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$7$$anonfun$8.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val convertedMap: java.util.Map[TopicPartition, java.lang.Long] =
partitionAndOffsets.mapValues(_.asInstanceOf[java.lang.Long]).asJava
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:393:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$close$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
error("Exception closing nioSelector:", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:393:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$close$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
error("Exception closing nioSelector:", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:360:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$deleteConsumerGroups$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
groups.foreach { group =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:375:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$deleteConsumerGroups$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
groupsPerCoordinator.foreach { case (coordinator, groups) =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:378:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$deleteConsumerGroups$2$$anonfun$apply$5.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
groups.foreach {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:240:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$deleteRecordsBefore$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
error(s"Metadata request contained errors: $errors")
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:322:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$describeConsumerGroup$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"The consumer group response for group '$groupId' is invalid.
Retrying the request as the group is initializing ...")
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:166:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$findAllBrokers$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"Metadata request contained errors: $errors")
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:95:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$kafka$admin$AdminClient$$sendAnyNode$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
bootstrapBrokers.foreach { broker =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:102:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$kafka$admin$AdminClient$$sendAnyNode$1$$anonfun$apply$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"Request $api failed against node $broker", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:102:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$kafka$admin$AdminClient$$sendAnyNode$1$$anonfun$apply$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"Request $api failed against node $broker", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:215:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllBrokerVersionInfo$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
findAllBrokers().map { broker =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:216:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllBrokerVersionInfo$1$$anonfun$apply$4.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
broker -> Try[NodeApiVersions](new
NodeApiVersions(getApiVersions(broker).asJava))
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:185:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllConsumerGroups$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
listAllGroups().mapValues { groups =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:186:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllConsumerGroups$1$$anonfun$apply$3.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
groups.filter(isConsumerGroup)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:195:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllConsumerGroupsFlattened$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
listAllGroupsFlattened().filter(isConsumerGroup)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:171:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllGroups$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
findAllBrokers().map { broker =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:177:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllGroups$1$$anonfun$liftedTree1$1$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"Failed to find groups from broker $broker", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:177:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listAllGroups$1$$anonfun$liftedTree1$1$2.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
debug(s"Failed to find groups from broker $broker", e)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:211:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listGroupOffsets$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
response.responseData.asScala.map { case (tp, partitionData) => (tp,
partitionData.offset) }.toMap
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:140:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$listGroups$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
response.groups.asScala.map(group => GroupOverview(group.groupId,
group.protocolType)).toList
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:112:
error writing <$anon: Function0>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$$anonfun$sendRequest$1$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
Try(sendAnyNode(ApiKeys.FIND_COORDINATOR,
requestBuilder).asInstanceOf[FindCoordinatorResponse])
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:478:
error writing class AdminClient$AdminConfig:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$AdminConfig.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
class AdminConfig(originals: Map[_,_]) extends AbstractConfig(AdminConfigDef,
originals.asJava, false)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:297:
error writing class AdminClient$ConsumerGroupSummary:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$ConsumerGroupSummary.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
case class ConsumerGroupSummary(state: String,
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:289:
error writing object AdminClient$ConsumerSummary:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$ConsumerSummary$.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
case class ConsumerSummary(consumerId: String,
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminClient.scala>:476:
error writing class AdminClient$DeleteRecordsResult:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminClient$DeleteRecordsResult.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
case class DeleteRecordsResult(lowWatermark: Long, error: Exception)
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminOperationException.scala>:20:
error writing class AdminOperationException:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminOperationException.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
class AdminOperationException(val error: String, cause: Throwable) extends
RuntimeException(error, cause) {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:36:
error writing trait AdminUtilities:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminUtilities.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
trait AdminUtilities {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:64:
error writing object AdminUtils:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminUtils.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
object AdminUtils extends Logging with AdminUtilities {
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:179:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminUtils$$anonfun$1.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val brokerRackMap = brokerMetadatas.collect { case BrokerMetadata(id,
Some(rack)) =>
^
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:357:
error writing <$anon: Function1>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka/admin/AdminUtils$$anonfun$10.class>:
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/classes/scala/main/kafka>
is not a directory
val repFactors = sortedBadRepFactors.map { case (_, rf) => rf }
^
114 warnings found
5285 errors found
:kafka-trunk-jdk7:core:compileScala FAILED
:test_core_2_11 FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':kafka-trunk-jdk7:core:compileScala'.
> 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
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
See
https://docs.gradle.org/4.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 59s
24 actionable tasks: 3 executed, 21 up-to-date
FAILURE: Build failed with an exception.
* What went wrong:
Could not add entry ':core:compileScala' to cache taskHistory.bin
(<https://builds.apache.org/job/kafka-trunk-jdk7/ws/.gradle/4.5.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
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
See
https://docs.gradle.org/4.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 0s
Build step 'Execute shell' marked build as failure
[FINDBUGS] Collecting findbugs analysis files...
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
[FINDBUGS] Searching for all files in
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/> that match the pattern
**/build/reports/findbugs/*.xml
[FINDBUGS] No files found. Configuration error?
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
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=4f7c11a1df26836c7a15f062a5431adb3d371a86,
workspace=<https://builds.apache.org/job/kafka-trunk-jdk7/ws/>
[FINDBUGS] Computing warning deltas based on reference build #3414
Recording test results
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?
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
Not sending mail to unregistered user [email protected]
