[
https://issues.apache.org/jira/browse/KAFKA-16114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825363#comment-17825363
]
Divij Vaidya commented on KAFKA-16114:
--------------------------------------
Sorry [~albedooooooo] , I won't have bandwidth any time soon to look into this.
> Fix partiton not retention after cancel alter intra broker log dir task
> ------------------------------------------------------------------------
>
> Key: KAFKA-16114
> URL: https://issues.apache.org/jira/browse/KAFKA-16114
> Project: Kafka
> Issue Type: Bug
> Components: log
> Affects Versions: 3.3.2, 3.6.1
> Reporter: wangliucheng
> Priority: Major
>
> The deletion thread will not work on partition after cancel alter intra
> broker log dir task
> The steps to reproduce are as follows:
> 1、Create reassignment.json file
> test01-1 on the /data01/kafka/log01 directory of the broker 1003，then move to
> /data01/kafka/log02
> {code:java}
> {
> "version": 1,
> "partitions": [
> {
> "topic": "test01",
> "partition": 1,
> "replicas": [1001,1003],
> "log_dirs": ["any","/data01/kafka/log02"]
> }
> ]
> }{code}
> 2、Kick off the reassignment
> {code:java}
> bin/kafka-reassign-partitions.sh -bootstrap-server localhost:9092
> --reassignment-json-file reassignment.json -execute {code}
> 3、Cancel the reassignment
> {code:java}
> bin/kafka-reassign-partitions.sh -bootstrap-server localhost:9092
> --reassignment-json-file reassignment.json -cancel {code}
> 4、Result, The partition test01-1 on 1003 will not be deleted
> The reason for this problem is the partition has been filtered:
> {code:java}
> val deletableLogs = logs.filter {
> case (_, log) => !log.config.compact // pick non-compacted logs
> }.filterNot {
> case (topicPartition, _) => inProgress.contains(topicPartition) // skip any
> logs already in-progress
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
