longbowen opened a new issue, #286: URL: https://github.com/apache/rocketmq-streams/issues/286
实际场景在本地和K8S集群中都可以重现，比如k8S集群缩容时。 这是因为网络问题导致的？ 2023-04-28T10:33:15.086539482+08:00 2023-04-28 10:33:15.086 [,] [pool-7-thread-5] ERROR o.apache.rocketmq.streams.core.state.RocketMQStore - [lambda$removeState$1,279] - remove state error 2023-04-28T10:33:15.086594456+08:00 java.lang.NullPointerException: null 2023-04-28T10:33:15.086601395+08:00 at java.util.AbstractCollection.addAll(AbstractCollection.java:343) 2023-04-28T10:33:15.086605769+08:00 at org.apache.rocketmq.streams.core.state.AbstractStore$Wrapper.getAll(AbstractStore.java:156) 2023-04-28T10:33:15.086609858+08:00 at org.apache.rocketmq.streams.core.state.AbstractStore.getAll(AbstractStore.java:53) 2023-04-28T10:33:15.086614229+08:00 at org.apache.rocketmq.streams.core.state.RocketMQStore.lambda$removeState$1(RocketMQStore.java:267) 2023-04-28T10:33:15.086618636+08:00 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 2023-04-28T10:33:15.086641504+08:00 at java.util.concurrent.FutureTask.run(FutureTask.java:266) 2023-04-28T10:33:15.086645641+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 2023-04-28T10:33:15.086649929+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 2023-04-28T10:33:15.086653477+08:00 at java.lang.Thread.run(Thread.java:748) 2023-04-28T10:33:15.091102054+08:00 2023-04-28 10:33:15.090 [,] [RebalanceService] ERROR o.a.rocketmq.streams.core.running.WorkerThread - [lambda$new$0,145] - recover error. 2023-04-28T10:33:15.091135289+08:00 java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.NullPointerException 2023-04-28T10:33:15.091142105+08:00 at java.util.concurrent.FutureTask.report(FutureTask.java:122) 2023-04-28T10:33:15.091146330+08:00 at java.util.concurrent.FutureTask.get(FutureTask.java:206) 2023-04-28T10:33:15.091150340+08:00 at org.apache.rocketmq.streams.core.state.RocketMQStore.removeState(RocketMQStore.java:285) 2023-04-28T10:33:15.091155282+08:00 at org.apache.rocketmq.streams.core.state.RocketMQStore.recover(RocketMQStore.java:85) 2023-04-28T10:33:15.091159248+08:00 at org.apache.rocketmq.streams.core.running.WorkerThread$PlanetaryEngine.lambda$new$0(WorkerThread.java:142) 2023-04-28T10:33:15.091162330+08:00 at org.apache.rocketmq.streams.core.running.MessageQueueListenerWrapper.messageQueueChanged(MessageQueueListenerWrapper.java:64) 2023-04-28T10:33:15.091165820+08:00 at org.apache.rocketmq.client.impl.consumer.RebalanceLitePullImpl.messageQueueChanged(RebalanceLitePullImpl.java:53) 2023-04-28T10:33:15.091168893+08:00 at org.apache.rocketmq.client.impl.consumer.RebalanceImpl.rebalanceByTopic(RebalanceImpl.java:369) 2023-04-28T10:33:15.091173800+08:00 at org.apache.rocketmq.client.impl.consumer.RebalanceImpl.doRebalance(RebalanceImpl.java:252) 2023-04-28T10:33:15.091178229+08:00 at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.doRebalance(DefaultLitePullConsumerImpl.java:1109) 2023-04-28T10:33:15.091182348+08:00 at org.apache.rocketmq.client.impl.factory.MQClientInstance.doRebalance(MQClientInstance.java:938) 2023-04-28T10:33:15.091187258+08:00 at org.apache.rocketmq.client.impl.consumer.RebalanceService.run(RebalanceService.java:41) 2023-04-28T10:33:15.091194086+08:00 at java.lang.Thread.run(Thread.java:748) 2023-04-28T10:33:15.091200842+08:00 Caused by: java.lang.RuntimeException: java.lang.NullPointerException 2023-04-28T10:33:15.091204858+08:00 at org.apache.rocketmq.streams.core.state.RocketMQStore.lambda$removeState$1(RocketMQStore.java:280) 2023-04-28T10:33:15.091209289+08:00 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 2023-04-28T10:33:15.091214210+08:00 at java.util.concurrent.FutureTask.run(FutureTask.java:266) 2023-04-28T10:33:15.091217565+08:00 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 2023-04-28T10:33:15.091220779+08:00 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 2023-04-28T10:33:15.091224304+08:00 ... 1 common frames omitted 2023-04-28T10:33:15.091227380+08:00 Caused by: java.lang.NullPointerException: null 2023-04-28T10:33:15.091230380+08:00 at java.util.AbstractCollection.addAll(AbstractCollection.java:343) 2023-04-28T10:33:15.091233731+08:00 at org.apache.rocketmq.streams.core.state.AbstractStore$Wrapper.getAll(AbstractStore.java:156) 2023-04-28T10:33:15.091236557+08:00 at org.apache.rocketmq.streams.core.state.AbstractStore.getAll(AbstractStore.java:53) 2023-04-28T10:33:15.091239422+08:00 at org.apache.rocketmq.streams.core.state.RocketMQStore.lambda$removeState$1(RocketMQStore.java:267) 2023-04-28T10:33:15.091242203+08:00 ... 5 common frames omitted -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
