You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "longbowen (via GitHub)" <gi...@apache.org> on 2023/04/28 03:46:41 UTC
[GitHub] [rocketmq-streams] longbowen opened a new issue, #286: 启动多个实例时，关闭其中一个实例后，另外一个实例报错
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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] ni-ze commented on issue #286: Instance reports an error, after another instance closed.
Posted by "ni-ze (via GitHub)" <gi...@apache.org>.
ni-ze commented on issue #286:
URL: https://github.com/apache/rocketmq-streams/issues/286#issuecomment-1533989618
@longbowen I fix this, please review it. thanks.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] ni-ze closed issue #286: Instance reports an error, after another instance closed.
Posted by "ni-ze (via GitHub)" <gi...@apache.org>.
ni-ze closed issue #286: Instance reports an error, after another instance closed.
URL: https://github.com/apache/rocketmq-streams/issues/286
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org