[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-8972: ------------------------------- Description: test `test_broker_type_bounce` could sometimes fail due to NPE in changelog restoration: ``` [2019-09-30 15:22:43,574] ERROR stream-thread [SmokeTest-357607f6-655b-4b3c-ad3e-f5e5e19df83e-StreamThread-2] Encountered the following error during processing: (org.apache.kafka.streams.processor.internals.StreamThread) java.lang.NullPointerException at org.apache.kafka.streams.state.internals.RocksDBStore.toggleDbForBulkLoading(RocksDBStore.java:403) at org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBBatchingRestoreCallback.onRestoreStart(RocksDBStore.java:650) at org.apache.kafka.streams.processor.internals.CompositeRestoreListener.onRestoreStart(CompositeRestoreListener.java:59) at org.apache.kafka.streams.processor.internals.StateRestorer.restoreStarted(StateRestorer.java:76) at org.apache.kafka.streams.processor.internals.StoreChangelogReader.startRestoration(StoreChangelogReader.java:205) at org.apache.kafka.streams.processor.internals.StoreChangelogReader.initialize(StoreChangelogReader.java:181) at org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:79) at org.apache.kafka.streams.processor.internals.TaskManager.updateNewAndRestoringTasks(TaskManager.java:327) at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:863) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:792) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:761)``` Seems to be some bug with dbAccessor initialization. was:test `test_broker_type_bounce` could sometimes fail due to a task migrated exception by the end of test. This is because during cluster rolling bounce the member could timeout and be rejected from rejoining the group. A proper fix would be improving the resilience of stream client by making session timeout longer. > Toggle bulkloading hit NPE > -------------------------- > > Key: KAFKA-8972 > URL: https://issues.apache.org/jira/browse/KAFKA-8972 > Project: Kafka > Issue Type: Bug > Reporter: Boyang Chen > Assignee: Boyang Chen > Priority: Major > > test `test_broker_type_bounce` could sometimes fail due to NPE in changelog > restoration: > > ``` > [2019-09-30 15:22:43,574] ERROR stream-thread > [SmokeTest-357607f6-655b-4b3c-ad3e-f5e5e19df83e-StreamThread-2] Encountered > the following error during processing: > (org.apache.kafka.streams.processor.internals.StreamThread) > java.lang.NullPointerException > at > org.apache.kafka.streams.state.internals.RocksDBStore.toggleDbForBulkLoading(RocksDBStore.java:403) > at > org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBBatchingRestoreCallback.onRestoreStart(RocksDBStore.java:650) > at > org.apache.kafka.streams.processor.internals.CompositeRestoreListener.onRestoreStart(CompositeRestoreListener.java:59) > at > org.apache.kafka.streams.processor.internals.StateRestorer.restoreStarted(StateRestorer.java:76) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.startRestoration(StoreChangelogReader.java:205) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.initialize(StoreChangelogReader.java:181) > at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:79) > at > org.apache.kafka.streams.processor.internals.TaskManager.updateNewAndRestoringTasks(TaskManager.java:327) > at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:863) > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:792) > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:761)``` > Seems to be some bug with dbAccessor initialization. -- This message was sent by Atlassian Jira (v8.3.4#803005)