[jira] [Created] (KAFKA-9721) ReassignPartitionsCommand#reassignPartitions does not

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

Chia-Ping Tsai created KAFKA-9721:
-------------------------------------

             Summary: ReassignPartitionsCommand#reassignPartitions does not
                 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


{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)