Amit Gupta created KAFKA-13346:
----------------------------------
Summary: Kafka Streams fails due to unexpected exception
Key: KAFKA-13346
URL: https://issues.apache.org/jira/browse/KAFKA-13346
Project: Kafka
Issue Type: Bug
Affects Versions: 2.6.0
Reporter: Amit Gupta
Hello,
We are using Kafka Streams and we observe that some times on some of the hosts
running streams application, Kafka streams instance fails with unexpected
exception.
|org.apache.kafka.streams.errors.ProcessorStateException: Error opening store
state-store at location .....
at
org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:214)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:188)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:224)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:48)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.init(ChangeLoggingKeyValueBytesStore.java:42)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:48)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$init$0(MeteredKeyValueStore.java:101)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:836)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:101)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.ProcessorStateManager.registerStateStores(ProcessorStateManager.java:199)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.StateManagerUtil.registerStateStores(StateManagerUtil.java:76)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.StandbyTask.initializeIfNeeded(StandbyTask.java:95)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.TaskManager.tryToCompleteRestoration(TaskManager.java:426)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:660)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:551)
~[kafka-streams-2.6.0.jar:?]
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:510)
~[kafka-streams-2.6.0.jar:?]
Caused by: org.rocksdb.RocksDBException: lock :
...../0_468/rocksdb/state-store/LOCK: No locks available
at org.rocksdb.RocksDB.open(Native Method) ~[rocksdbjni-5.18.3.jar:?]
at org.rocksdb.RocksDB.open(RocksDB.java:286) ~[rocksdbjni-5.18.3.jar:?]
at
org.apache.kafka.streams.state.internals.RocksDBStore.openRocksDB(RocksDBStore.java:211)
~[kafka-streams-2.6.0.jar:?]
... 15 more|
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
