[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16125778#comment-16125778 ]
ASF GitHub Bot commented on KAFKA-5733: --------------------------------------- GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/3664 KAFKA-5733: ensure clean RocksDB directory before setting prepareForB… …ulkload settings You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka KAFKA-5733_rocks_db_throws_more_than_num_levels_on_restore Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3664.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3664 ---- commit 2cfc54c8e77b840acc0d176cea8eabda4d1c4b03 Author: Bill Bejeck <b...@confluent.io> Date: 2017-08-14T14:46:08Z KAFKA-5733: ensure clean RocksDB directory before setting prepareForBulkload settings ---- > System tests get exception RocksDBException: db has more levels than > options.num_levels > --------------------------------------------------------------------------------------- > > Key: KAFKA-5733 > URL: https://issues.apache.org/jira/browse/KAFKA-5733 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.1 > Reporter: Eno Thereska > Fix For: 0.11.0.1 > > > New system tests as part of KAFKA-5725 with PR > https://github.com/apache/kafka/pull/3656 consistently fail like this: > [2017-08-14 10:37:57,216] ERROR User provided listener > org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener > for group SmokeTest failed on partition assignment > (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) > org.apache.kafka.streams.errors.ProcessorStateException: Error opening store > cntStoreName at location /mnt/streams/SmokeTest/2_0/rocksdb/cntStoreName > at > org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:206) > at > org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:176) > at > org.apache.kafka.streams.state.internals.RocksDBStore.toggleDbForBulkLoading(RocksDBStore.java:259) > at > org.apache.kafka.streams.state.internals.RocksDBStore.access$200(RocksDBStore.java:74) > at > org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBBatchingRestoreCallback.onRestoreStart(RocksDBStore.java:551) > at > org.apache.kafka.streams.processor.internals.CompositeRestoreListener.onRestoreStart(CompositeRestoreListener.java:54) > at > org.apache.kafka.streams.processor.internals.StateRestorer.restoreStarted(StateRestorer.java:61) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:126) > at > org.apache.kafka.streams.processor.internals.TaskManager.createTasks(TaskManager.java:94) > at > org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:177) > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:368) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:317) > 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:736) > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:707) > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:677) > Caused by: org.rocksdb.RocksDBException: db has more levels than > options.num_levels > 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:199) -- This message was sent by Atlassian JIRA (v6.4.14#64029)