[jira] [Created] (KAFKA-9495) Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk

["Matthias J. Sax (Jira)" <ji...@apache.org>]

Matthias J. Sax created KAFKA-9495:
--------------------------------------

             Summary: Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk
                 Key: KAFKA-9495
                 URL: https://issues.apache.org/jira/browse/KAFKA-9495
             Project: Kafka
          Issue Type: Bug
          Components: admin, core, unit tests
    Affects Versions: 2.5.0
            Reporter: Matthias J. Sax


[https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4462/testReport/junit/kafka.admin/ReassignPartitionsClusterTest/shouldListReassignmentsTriggeredByZk/]
{quote}java.lang.NullPointerException at kafka.admin.ReassignPartitionsClusterTest.assertIsReassigning(ReassignPartitionsClusterTest.scala:1191) at kafka.admin.ReassignPartitionsClusterTest.shouldListReassignmentsTriggeredByZk(ReassignPartitionsClusterTest.scala:727){quote}
STDOUT
{quote}[2020-02-01 20:18:33,300] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Warning: You must run Verify periodically, until the reassignment completes, to ensure the throttle is removed. You can also alter the throttle by rerunning the Execute command passing a new value. The inter-broker throttle limit was set to 10000000 B/s Successfully started reassignment of partitions. [2020-02-01 20:18:50,051] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:18:50,052] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:18:50,155] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:18:50,155] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[101,100],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[101,100],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Warning: You must run Verify periodically, until the reassignment completes, to ensure the throttle is removed. You can also alter the throttle by rerunning the Execute command passing a new value. The inter-broker throttle limit was set to 1000000 B/s Successfully started reassignment of partitions. [2020-02-01 20:19:05,147] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,244] ERROR [ReplicaFetcher replicaId=104, leaderId=103, fetcherId=0] Error for partition topic1-2 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,247] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition topic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,248] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,351] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition topic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,351] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,753] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,753] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,856] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,856] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,958] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:18,958] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:19,060] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:19,060] ERROR [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[103,104],"log_dirs":["any","any"]},\{"topic":"topic2","partition":0,"replicas":[104,105],"log_dirs":["any","any"]},\{"topic":"topic1","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"topic2","partition":2,"replicas":[103,104],"log_dirs":["any","any"]},\{"topic":"topic2","partition":1,"replicas":[104,105],"log_dirs":["any","any"]},\{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Warning: You must run Verify periodically, until the reassignment completes, to ensure the throttle is removed. You can also alter the throttle by rerunning the Execute command passing a new value. The inter-broker throttle limit was set to 1000000 B/s Successfully started reassignment of partitions. [2020-02-01 20:19:23,666] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:23,666] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:23,666] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:23,770] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:23,770] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:23,770] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":2,"replicas":[100,101],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Current partition replica assignment \{"version":1,"partitions":[{"topic":"A","partition":0,"replicas":[100],"log_dirs":["any"]},\{"topic":"A","partition":1,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. [2020-02-01 20:19:46,313] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,313] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,317] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,317] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,419] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,419] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,419] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:46,419] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:19:55,836] ERROR [ReplicaFetcher replicaId=102, leaderId=101, fetcherId=0] Error for partition my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":2,"replicas":[102,100],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Warning: You must run Verify periodically, until the reassignment completes, to ensure the throttle is removed. You can also alter the throttle by rerunning the Execute command passing a new value. The inter-broker throttle limit was set to 1000000 B/s Successfully started reassignment of partitions. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions. [2020-02-01 20:20:15,365] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,366] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,365] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,366] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,469] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,469] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,469] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:15,470] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. The inter-broker throttle limit was set to 1000 B/s [2020-02-01 20:20:21,504] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,710] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,764] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,765] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-2 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,765] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-3 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,868] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,868] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-2 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:24,868] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition orders-3 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:20:46,478] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Warning: You must run Verify periodically, until the reassignment completes, to ensure the throttle is removed. You can also alter the throttle by rerunning the Execute command passing a new value. The inter-broker throttle limit was set to 1000000 B/s Successfully started reassignment of partitions. Status of partition reassignment: Reassignment of partition my-topic-0 is still in progress There is an existing assignment running. Status of partition reassignment: Reassignment of partition my-topic-0 completed successfully Throttle was removed. [2020-02-01 20:20:51,944] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Current partition replica assignment \{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},\{"topic":"topic2","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"topic1","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"topic2","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},\{"topic":"topic2","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]} Save this to use as the --reassignment-json-file option during rollback Successfully started reassignment of partitions.{quote}



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