Do you have the logs leading up to the exception? On Mon, 14 Aug 2017 at 06:52 Sameer Kumar <sam.kum.w...@gmail.com> wrote:
> Exception while doing the join, cant decipher more on this. Has anyone > faced it. complete exception trace attached. > > 2017-08-14 11:15:55 ERROR ConsumerCoordinator:269 - User provided listener > org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener > for group c-7-a34 failed on partition assignment > org.apache.kafka.streams.errors.ProcessorStateException: Error opening > store KSTREAM-JOINTHIS-0000000018-store-201708140520 at location > /data/streampoc/c-7-a34/0_4/KSTREAM-JOINTHIS-0000000018-store/KSTREAM-JOINTHIS-0000000018-store-201708140520 > at > org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:198) > at > org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:165) > at > org.apache.kafka.streams.state.internals.Segment.openDB(Segment.java:40) > at > org.apache.kafka.streams.state.internals.Segments.getOrCreateSegment(Segments.java:86) > at > org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore.put(RocksDBSegmentedBytesStore.java:81) > at > org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore$1.restore(RocksDBSegmentedBytesStore.java:113) > at > org.apache.kafka.streams.processor.internals.StateRestorer.restore(StateRestorer.java:55) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.processNext(StoreChangelogReader.java:216) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restorePartition(StoreChangelogReader.java:186) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:151) > at > org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:184) > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:363) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:310) > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:297) > at > org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078) > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043) > at > org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:582) > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:553) > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:527) > Caused by: org.rocksdb.RocksDBException: > at org.rocksdb.RocksDB.open(Native Method) > at org.rocksdb.RocksDB.open(RocksDB.java:231) > at > org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:191) > ... 19 more > > -sameer. >
