[
https://issues.apache.org/jira/browse/KAFKA-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-9737:
----------------------------------
Assignee: (was: Tom Bentley)
> Describing log dir reassignment times out if broker is offline
> --------------------------------------------------------------
>
> Key: KAFKA-9737
> URL: https://issues.apache.org/jira/browse/KAFKA-9737
> Project: Kafka
> Issue Type: Bug
> Reporter: Jason Gustafson
> Priority: Major
>
> If there is any broker offline when trying to describe a log dir
> reassignment, then we get the something like the following error:
> {code}
> Status of partition reassignment:
>
> Partitions reassignment failed due to
> org.apache.kafka.common.errors.TimeoutException:
> Call(callName=describeReplicaLogDirs, deadlineMs=1584663960068, tries=1,
> nextAllowedTryMs=158466
> 3960173) timed out at 1584663960073 after 1 attempt(s)
>
>
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.TimeoutException:
> Call(callName=describeReplicaLogDirs, deadlineMs=1584663960068, tries=1,
> nextAllowedTryMs=158
> 4663960173) timed out at 1584663960073 after 1 attempt(s)
>
>
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
>
>
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
>
>
> at
> org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
>
>
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
>
>
> at
> kafka.admin.ReassignPartitionsCommand$.checkIfReplicaReassignmentSucceeded(ReassignPartitionsCommand.scala:381)
>
> at
> kafka.admin.ReassignPartitionsCommand$.verifyAssignment(ReassignPartitionsCommand.scala:98)
>
> at
> kafka.admin.ReassignPartitionsCommand$.verifyAssignment(ReassignPartitionsCommand.scala:90)
> at
> kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:61)
> at
> kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala)
> Caused by: org.apache.kafka.common.errors.TimeoutException:
> Call(callName=describeReplicaLogDirs, deadlineMs=1584663960068, tries=1,
> nextAllowedTryMs=1584663960173) timed out at 15846
> 63960073 after 1 attempt(s)
> Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting
> for a node assignment.
> {code}
> It would be nice if the tool was smart enough to notice brokers that are
> offline and report them as such while reporting the status of reassignments
> for online brokers.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
