[
https://issues.apache.org/jira/browse/KAFKA-16760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16760:
------------------------------
Description:
When firing alterLogDirRequest, it gets error NONE result. But actually, the
alterLogDir never happened with these errors:
{code:java}
[2024-05-14 16:48:50,796] INFO [ReplicaAlterLogDirsThread-1]: Partition
topicB-0 has an older epoch (0) than the current leader. Will await the new
LeaderAndIsr state before resuming fetching.
(kafka.server.ReplicaAlterLogDirsThread:66)
[2024-05-14 16:48:50,796] WARN [ReplicaAlterLogDirsThread-1]: Partition
topicB-0 marked as failed (kafka.server.ReplicaAlterLogDirsThread:70)
{code}
Note: It's under KRaft mode. So the log with LeaderAndIsr is wrong.
This can be reproduced in this
[branch|https://github.com/showuon/kafka/tree/alterLogDirTest] and running this
test:
{code:java}
./gradlew cleanTest storage:test --tests
org.apache.kafka.tiered.storage.integration.AlterLogDirTest
{code}
The complete logs can be found here:
https://gist.github.com/showuon/b16cdb05a125a7c445cc6e377a2b7923
was:
When firing alterLogDirRequest, it gets error NONE result. But actually, the
alterLogDir never happened with these errors:
{code:java}
[2024-05-14 16:48:50,796] INFO [ReplicaAlterLogDirsThread-1]: Partition
topicB-0 has an older epoch (0) than the current leader. Will await the new
LeaderAndIsr state before resuming fetching.
(kafka.server.ReplicaAlterLogDirsThread:66)
[2024-05-14 16:48:50,796] WARN [ReplicaAlterLogDirsThread-1]: Partition
topicB-0 marked as failed (kafka.server.ReplicaAlterLogDirsThread:70)
{code}
Note: It's under KRaft mode. This can be reproduced in this
[branch|https://github.com/showuon/kafka/tree/alterLogDirTest] and running this
test:
{code:java}
./gradlew cleanTest storage:test --tests
org.apache.kafka.tiered.storage.integration.AlterLogDirTest
{code}
The complete logs can be found here:
https://gist.github.com/showuon/b16cdb05a125a7c445cc6e377a2b7923
> alterReplicaLogDirs failed even if responded with none error
> ------------------------------------------------------------
>
> Key: KAFKA-16760
> URL: https://issues.apache.org/jira/browse/KAFKA-16760
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 3.7.0
> Reporter: Luke Chen
> Priority: Major
>
> When firing alterLogDirRequest, it gets error NONE result. But actually, the
> alterLogDir never happened with these errors:
> {code:java}
> [2024-05-14 16:48:50,796] INFO [ReplicaAlterLogDirsThread-1]: Partition
> topicB-0 has an older epoch (0) than the current leader. Will await the new
> LeaderAndIsr state before resuming fetching.
> (kafka.server.ReplicaAlterLogDirsThread:66)
> [2024-05-14 16:48:50,796] WARN [ReplicaAlterLogDirsThread-1]: Partition
> topicB-0 marked as failed (kafka.server.ReplicaAlterLogDirsThread:70)
> {code}
> Note: It's under KRaft mode. So the log with LeaderAndIsr is wrong.
> This can be reproduced in this
> [branch|https://github.com/showuon/kafka/tree/alterLogDirTest] and running
> this test:
> {code:java}
> ./gradlew cleanTest storage:test --tests
> org.apache.kafka.tiered.storage.integration.AlterLogDirTest
> {code}
> The complete logs can be found here:
> https://gist.github.com/showuon/b16cdb05a125a7c445cc6e377a2b7923
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
