[jira] [Resolved] (KAFKA-9721) ReassignPartitionsCommand#reassignPartitions doesn't wait for the completion of altering replica folder

["Chia-Ping Tsai (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-9721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chia-Ping Tsai resolved KAFKA-9721.
-----------------------------------
    Resolution: Won't Fix

ReassignPartitionsCommand does not guarantee to "complete" the replica move so close this issue as "Won't Fix".

> ReassignPartitionsCommand#reassignPartitions doesn't wait for the completion of altering replica folder
> -------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-9721
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9721
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Chia-Ping Tsai
>            Assignee: Chia-Ping Tsai
>            Priority: Major
>
> {code:scala}
>         val replicasAssignedToFutureDir = mutable.Set.empty[TopicPartitionReplica]
>         while (remainingTimeMs > 0 && replicasAssignedToFutureDir.size < proposedReplicaAssignment.size) {
>           replicasAssignedToFutureDir ++= alterReplicaLogDirsIgnoreReplicaNotAvailable(
>             proposedReplicaAssignment.filter { case (replica, _) => !replicasAssignedToFutureDir.contains(replica) },
>             adminClientOpt.get, remainingTimeMs)
>           Thread.sleep(100)
>           remainingTimeMs = startTimeMs + timeoutMs - System.currentTimeMillis()
>         }
> {code}
> The response of altering replica folder is NOT the completed folder since the alter process executes on another thread to move the data from source to target. Hence, it should depend on the response of #describeLogDirs rather than #alterReplicaLogDirs.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)