You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/08/04 06:30:10 UTC
[GitHub] [rocketmq-connect] Oliverwqcwrw opened a new issue, #234: Potential NPE
Oliverwqcwrw opened a new issue, #234:
URL: https://github.com/apache/rocketmq-connect/issues/234
**BUG REPORT**
1. Please describe the issue you observed:
- What did you do (The steps to reproduce)?
when I exec `org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectController#start`
then cause NPE
>
java.lang.NullPointerException
at org.apache.rocketmq.connect.runtime.service.ClusterManagementServiceImpl.start(ClusterManagementServiceImpl.java:90)
at org.apache.rocketmq.connect.runtime.controller.AbstractConnectController.start(AbstractConnectController.java:108)
at org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectController.start(StandaloneConnectController.java:53)
at org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectControllerTest.startTest(StandaloneConnectControllerTest.java:63)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.mockito.internal.runners.DefaultInternalRunner$1$1.evaluate(DefaultInternalRunner.java:46)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.mockito.internal.runners.DefaultInternalRunner$1.run(DefaultInternalRunner.java:77)
at org.mockito.internal.runners.DefaultInternalRunner.run(DefaultInternalRunner.java:83)
at org.mockito.internal.runners.StrictRunner.run(StrictRunner.java:39)
at org.mockito.junit.MockitoJUnitRunner.run(MockitoJUnitRunner.java:163)
The reason is that defaultMQPullConsumer is not initialized
- What is expected to see?
It do not occur NPE
- What did you see instead?
occur NPE
2. Please tell us about your environment:
master
4. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
we can initialize before start
In `org.apache.rocketmq.connect.runtime.controller.AbstractConnectController#start`
>
@Override
public void start() {
clusterManagementService.initialize(connectConfig);
clusterManagementService.start();
configManagementService.start();
positionManagementService.start();
worker.start();
connectStatsService.start();
}
--
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: dev-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] sunxiaojian commented on issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
sunxiaojian commented on issue #234:
URL: https://github.com/apache/rocketmq-connect/issues/234#issuecomment-1204835113
> **BUG REPORT**
>
> 1. Please describe the issue you observed:
>
> * What did you do (The steps to reproduce)?
>
> when I exec `org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectController#start`
>
> then cause NPE
>
> >
>
> ```
> java.lang.NullPointerException
> at org.apache.rocketmq.connect.runtime.service.ClusterManagementServiceImpl.start(ClusterManagementServiceImpl.java:90)
> at org.apache.rocketmq.connect.runtime.controller.AbstractConnectController.start(AbstractConnectController.java:108)
> at org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectController.start(StandaloneConnectController.java:53)
> at org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectControllerTest.startTest(StandaloneConnectControllerTest.java:63)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at org.mockito.internal.runners.DefaultInternalRunner$1$1.evaluate(DefaultInternalRunner.java:46)
> at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> at org.mockito.internal.runners.DefaultInternalRunner$1.run(DefaultInternalRunner.java:77)
> at org.mockito.internal.runners.DefaultInternalRunner.run(DefaultInternalRunner.java:83)
> at org.mockito.internal.runners.StrictRunner.run(StrictRunner.java:39)
> at org.mockito.junit.MockitoJUnitRunner.run(MockitoJUnitRunner.java:163)
> ```
>
> The reason is that defaultMQPullConsumer is not initialized
>
> * What is expected to see?
>
> It do not occur NPE
>
> * What did you see instead?
>
> occur NPE
>
> 2. Please tell us about your environment:
>
> master
>
> 4. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
>
> we can initialize before start
>
> In `org.apache.rocketmq.connect.runtime.controller.AbstractConnectController#start`
>
> >
>
> ```
> @Override
> public void start() {
> clusterManagementService.initialize(connectConfig);
> clusterManagementService.start();
> configManagementService.start();
> positionManagementService.start();
> worker.start();
> connectStatsService.start();
> }
> ```
defaultMQPullConsumer
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] Oliverwqcwrw closed issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
Oliverwqcwrw closed issue #234: Potential NPE
URL: https://github.com/apache/rocketmq-connect/issues/234
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] sunxiaojian commented on issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
sunxiaojian commented on issue #234:
URL: https://github.com/apache/rocketmq-connect/issues/234#issuecomment-1204834839
Standalone does not need to initialize defaultMQPullConsumer
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] sunxiaojian commented on issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
sunxiaojian commented on issue #234:
URL: https://github.com/apache/rocketmq-connect/issues/234#issuecomment-1204838695
It should have been initialized
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] Oliverwqcwrw commented on issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
Oliverwqcwrw commented on issue #234:
URL: https://github.com/apache/rocketmq-connect/issues/234#issuecomment-1204845905
`org.apache.rocketmq.connect.runtime.controller.standalone.StandaloneConnectController#start`
>
public void start() {
super.start();
rebalanceService.start();
}
It's called start, it's not initialized
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] Oliverwqcwrw commented on issue #234: Potential NPE
Posted by GitBox <gi...@apache.org>.
Oliverwqcwrw commented on issue #234:
URL: https://github.com/apache/rocketmq-connect/issues/234#issuecomment-1204870172
>  It should have been initialized
I understand your meaning
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org