kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Guozhang Wang (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-4960) Invalid state store exception
Date Mon, 04 Jun 2018 05:16:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Guozhang Wang resolved KAFKA-4960.
----------------------------------
    Resolution: Cannot Reproduce

> Invalid state store exception
> -----------------------------
>
>                 Key: KAFKA-4960
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4960
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.2.0
>            Reporter: j yeargers
>            Priority: Major
>         Attachments: text.html
>
>
> Attempts to run windowed aggregation returns this exception:
> 2017-03-27 20:14:28,776 [StreamThread-1] WARN   o.a.k.s.p.internals.StreamThread - Unexpected
state transition from RUNNING to NOT_RUNNING
> 2017-03-27 20:14:28,776 [StreamThread-1] WARN   o.a.k.s.p.internals.StreamThread - Unexpected
state transition from RUNNING to NOT_RUNNING
> Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException:
Exception caught in process. taskId=0_1, processor=KSTREAM-SOURCE-0000000000, topic=vi_preproc,
partition=1, offset=243574962
> 	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:216)
> 	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:641)
> 	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:368)
> Caused by: org.apache.kafka.streams.errors.InvalidStateStoreException: store %s has closed
> 	at org.apache.kafka.streams.state.internals.RocksDBStore$RocksDbIterator.hasNext(RocksDBStore.java:398)
> 	at org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBRangeIterator.hasNext(RocksDBStore.java:457)
> 	at org.apache.kafka.streams.state.internals.WindowStoreKeySchema$1.hasNext(WindowStoreKeySchema.java:30)
> 	at org.apache.kafka.streams.state.internals.SegmentIterator.hasNext(SegmentIterator.java:69)
> 	at org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStore$MeteredSegmentedBytesStoreIterator.hasNext(MeteredSegmentedBytesStore.java:131)
> 	at org.apache.kafka.streams.state.internals.RocksDBWindowStore$TheWindowStoreIterator.hasNext(RocksDBWindowStore.java:131)
> 	at org.apache.kafka.streams.state.internals.AbstractMergedSortedCacheStoreIterator.next(AbstractMergedSortedCacheStoreIterator.java:84)
> 	at org.apache.kafka.streams.state.internals.AbstractMergedSortedCacheStoreIterator.next(AbstractMergedSortedCacheStoreIterator.java:35)
> 	at org.apache.kafka.streams.kstream.internals.KStreamWindowReduce$KStreamWindowReduceProcessor.process(KStreamWindowReduce.java:94)
> 	at org.apache.kafka.streams.processor.internals.ProcessorNode$1.run(ProcessorNode.java:48)
> 	at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:188)
> 	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:134)
> 	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:83)
> 	at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:70)
> 	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:197)
> 	... 2 more



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message