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.
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
2017-08-14 11:15:55 INFO  StreamThread:193 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-8] partition 
assignment took 1797 ms.
        current active tasks: [0_56, 0_41, 0_26, 0_11]
        current standby tasks: []
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-JOINOTHER-0000000019-store-201708140520 at location 
/data/streampoc/c-7-a34/0_11/KSTREAM-JOINOTHER-0000000019-store/KSTREAM-JOINOTHER-0000000019-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
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-11] Shutting down
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-8] Shutting down
2017-08-14 11:15:55 INFO  StreamThread:193 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-3] partition 
assignment took 1803 ms.
        current active tasks: [0_51, 0_36, 0_21, 0_6]
        current standby tasks: []
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_21/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
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-3] Shutting down
2017-08-14 11:15:55 INFO  StreamThread:193 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] partition 
assignment took 1830 ms.
        current active tasks: [0_54, 0_39, 0_24, 0_9]
        current standby tasks: []
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-JOINOTHER-0000000019-store-201708140520 at location 
/data/streampoc/c-7-a34/0_39/KSTREAM-JOINOTHER-0000000019-store/KSTREAM-JOINOTHER-0000000019-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
2017-08-14 11:15:55 INFO  StreamThread:193 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-6] partition 
assignment took 1830 ms.
        current active tasks: [0_50, 0_35, 0_20, 0_5]
        current standby tasks: []
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-JOINOTHER-0000000019-store-201708140520 at location 
/data/streampoc/c-7-a34/0_5/KSTREAM-JOINOTHER-0000000019-store/KSTREAM-JOINOTHER-0000000019-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
2017-08-14 11:15:55 INFO  StreamThread:193 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-10] partition 
assignment took 1831 ms.
        current active tasks: [0_53, 0_38, 0_23, 0_8]
        current standby tasks: []
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-JOINOTHER-0000000019-store-201708140520 at location 
/data/streampoc/c-7-a34/0_8/KSTREAM-JOINOTHER-0000000019-store/KSTREAM-JOINOTHER-0000000019-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
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-10] Shutting down
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-6] Shutting down
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Shutting down
2017-08-14 11:15:55 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-2] Deleting obsolete 
state directory 0_40 for task 0_40 as cleanup delay of 9223372036854775807 ms 
has passed
2017-08-14 11:15:55 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-15] Deleting 
obsolete state directory 0_24 for task 0_24 as cleanup delay of 
9223372036854775807 ms has passed
2017-08-14 11:15:55 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-15] Deleting 
obsolete state directory 0_10 for task 0_10 as cleanup delay of 
9223372036854775807 ms has passed
2017-08-14 11:15:55 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-15] Deleting 
obsolete state directory 0_22 for task 0_22 as cleanup delay of 
9223372036854775807 ms has passed
2017-08-14 11:15:55 INFO  StreamThread:1040 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-7] Shutting down
2017-08-14 11:15:55 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-4] Deleting obsolete 
state directory 0_54 for task 0_54 as cleanup delay of 9223372036854775807 ms 
has passed
2017-08-14 11:15:55 INFO  KafkaProducer:972 - Closing the Kafka producer with 
timeoutMillis = 9223372036854775807 ms.
2017-08-14 11:15:55 INFO  StreamThread:1407 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Removing all 
active tasks [0_54, 0_39, 0_24, 0_9]
2017-08-14 11:15:55 INFO  StreamThread:1421 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Removing all 
standby tasks []
2017-08-14 11:15:55 INFO  StreamThread:1072 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Stream thread 
shutdown complete
2017-08-14 11:15:55 WARN  StreamThread:978 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Unexpected state 
transition from ASSIGNING_PARTITIONS to DEAD.
2017-08-14 11:15:55 INFO  KafkaStreams:229 - stream-client 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241] State transition from 
REBALANCING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-1] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-1] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-2] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-2] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-3] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-3] State transition 
from ASSIGNING_PARTITIONS to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-4] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-4] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Informed thread 
to shut down
2017-08-14 11:15:55 WARN  StreamThread:978 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-5] Unexpected state 
transition from DEAD to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-6] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-6] State transition 
from ASSIGNING_PARTITIONS to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-7] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-7] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-8] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-8] State transition 
from ASSIGNING_PARTITIONS to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-9] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-9] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-10] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-10] State transition 
from ASSIGNING_PARTITIONS to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-11] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-11] State transition 
from ASSIGNING_PARTITIONS to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-12] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-12] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-13] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-13] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-14] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-14] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:55 INFO  StreamThread:900 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-15] Informed thread 
to shut down
2017-08-14 11:15:55 INFO  StreamThread:980 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-15] State transition 
from RUNNING to PENDING_SHUTDOWN.
2017-08-14 11:15:56 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-1] Deleting obsolete 
state directory 0_51 for task 0_51 as cleanup delay of 9223372036854775807 ms 
has passed
2017-08-14 11:15:56 INFO  StateDirectory:220 - stream-thread 
[c-7-a34-2b29e007-c317-416a-9819-a869ddfc8241-StreamThread-1] De

Reply via email to