[ https://issues.apache.org/jira/browse/KAFKA-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Igor Soarez resolved KAFKA-16404. --------------------------------- Resolution: Not A Bug Same as KAFKA-16403, this only failed once. It was likely the result of a testing infrastructure problem. We can always re-open if we see this again and suspect otherwise. > Flaky test > org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testGetStreamsConfig > --------------------------------------------------------------------------------------------- > > Key: KAFKA-16404 > URL: https://issues.apache.org/jira/browse/KAFKA-16404 > Project: Kafka > Issue Type: Bug > Reporter: Igor Soarez > Priority: Major > > > {code:java} > org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testGetStreamsConfig() > failed, log available in > /home/jenkins/workspace/Kafka_kafka-pr_PR-14903@2/streams/examples/build/reports/testOutput/org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testGetStreamsConfig().test.stdout > Gradle Test Run :streams:examples:test > Gradle Test Executor 87 > > WordCountDemoTest > testGetStreamsConfig() 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 > app//org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:329) > at > app//org.apache.kafka.streams.state.internals.RocksDBTimestampedStore.openRocksDB(RocksDBTimestampedStore.java:69) > at > app//org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:254) > at > app//org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:175) > at > app//org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:71) > at > app//org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.init(ChangeLoggingKeyValueBytesStore.java:56) > at > app//org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:71) > at > app//org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$init$3(MeteredKeyValueStore.java:151) > at > app//org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:872) > at > app//org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:151) > at > app//org.apache.kafka.streams.processor.internals.ProcessorStateManager.registerStateStores(ProcessorStateManager.java:232) > at > app//org.apache.kafka.streams.processor.internals.StateManagerUtil.registerStateStores(StateManagerUtil.java:102) > at > app//org.apache.kafka.streams.processor.internals.StreamTask.initializeIfNeeded(StreamTask.java:258) > at > app//org.apache.kafka.streams.TopologyTestDriver.setupTask(TopologyTestDriver.java:530) > at > app//org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:373) > at > app//org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:300) > at > app//org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:276) > at > app//org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.setup(WordCountDemoTest.java:60) > Caused by: > org.rocksdb.RocksDBException: While lock file: > /tmp/kafka-streams/streams-wordcount/0_0/rocksdb/KSTREAM-AGGREGATE-STATE-STORE-0000000003/LOCK: > Resource temporarily unavailable > at app//org.rocksdb.RocksDB.open(Native Method) > at app//org.rocksdb.RocksDB.open(RocksDB.java:307) > at > app//org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:323) > ... 17 more > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)