[KAFKA-16403] Flaky test org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testCountListOfWords

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Not A Bug
• Assignee: Unassigned
• Reporter: Igor Soarez
• Created: 22/Mar/24 10:42
• Updated: 27/Mar/24 09:22
• Resolved: 27/Mar/24 09:22

Description

org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testCountListOfWords() failed, log available in /home/jenkins/workspace/Kafka_kafka-pr_PR-14903/streams/examples/build/reports/testOutput/org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testCountListOfWords().test.stdout
Gradle Test Run :streams:examples:test > Gradle Test Executor 82 > WordCountDemoTest > testCountListOfWords() FAILED
    org.apache.kafka.streams.errors.ProcessorStateException: Error opening store KSTREAM-AGGREGATE-STATE-STORE-0000000003 at location /tmp/kafka-streams/streams-wordcount/0_0/rocksdb/KSTREAM-AGGREGATE-STATE-STORE-0000000003
        at org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:329)
        at org.apache.kafka.streams.state.internals.RocksDBTimestampedStore.openRocksDB(RocksDBTimestampedStore.java:69)
        at org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:254)
        at org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:175)
        at org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:71)
        at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.init(ChangeLoggingKeyValueBytesStore.java:56)
        at org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:71)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$init$3(MeteredKeyValueStore.java:151)
        at org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:872)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:151)
        at org.apache.kafka.streams.processor.internals.ProcessorStateManager.registerStateStores(ProcessorStateManager.java:232)
        at org.apache.kafka.streams.processor.internals.StateManagerUtil.registerStateStores(StateManagerUtil.java:102)
        at org.apache.kafka.streams.processor.internals.StreamTask.initializeIfNeeded(StreamTask.java:258)
        at org.apache.kafka.streams.TopologyTestDriver.setupTask(TopologyTestDriver.java:530)
        at org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:373)
        at org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:300)
        at org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:276)
        at org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.setup(WordCountDemoTest.java:60)
        Caused by:
        org.rocksdb.RocksDBException: Corruption: IO error: No such file or directory: While open a file for random read: /tmp/kafka-streams/streams-wordcount/0_0/rocksdb/KSTREAM-AGGREGATE-STATE-STORE-0000000003/000010.ldb: No such file or directory in file /tmp/kafka-streams/streams-wordcount/0_0/rocksdb/KSTREAM-AGGREGATE-STATE-STORE-0000000003/MANIFEST-000005
            at org.rocksdb.RocksDB.open(Native Method)
            at org.rocksdb.RocksDB.open(RocksDB.java:307)
            at org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:323)
            ... 17 more