Hi all,
We are having a clustered deployment of CEP 400 Beta in Stratos 4.1.0(in
Kubernetes), similar to following. Instead of using hazelcast clustering,
I'm using 'Stratos Membership scheme' [1] which considers all the members
in the carbon cluster as well-known members. I have done CEP Distributed
deployment according to [3][4].
[image: Inline image 1]
When CEP workers start up, I can see the following log [2] in worker nodes.
10.244.28.23/24 are manager IPs. When the CEP managers are restarted, the
error goes away(Workers can connect to CEP Manager).
According to above membership scheme, any of the CEP workers/managers can
be the hazelcast coordinator. *Does CEP requires a member who is both CEP
manager as well as a hazelcast coordinator to be elected as the Storm
manager? *
Should CEP workers be always non-wka? How can we overcome this issue?
[1] [Architecture] Stratos Membership Scheme for Automatically Discovering
Carbon Instances in a Carbon Cluster
[2]
TID: [-1] [] [2015-07-27 04:51:11,885] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error registering CEP publisher with
current manager. Retrying after 5000ms
TID: [-1] [] [2015-07-27 04:51:16,887] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error in registering CEP publisher
for 10.244.28.24:15000 with manager 10.244.28.23:8904. Trying next manager
NotStormManagerException(message:10.244.28.23:8904 not a storm manager)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$registerCEPPublisher_result.read(StormManagerService.java:2116)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.recv_registerCEPPublisher(StormManagerService.java:120)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.registerCEPPublisher(StormManagerService.java:104)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.registerCEPPublisherWithStormMangerService(SiddhiStormOutputEventListener.java:181)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.run(SiddhiStormOutputEventListener.java:128)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
TID: [-1] [] [2015-07-27 04:51:16,890] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error in registering CEP publisher
for 10.244.28.24:15000 with manager 10.244.3.29:8904. Trying next manager
NotStormManagerException(message:10.244.3.29:8904 not a storm manager)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$registerCEPPublisher_result.read(StormManagerService.java:2116)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.recv_registerCEPPublisher(StormManagerService.java:120)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.registerCEPPublisher(StormManagerService.java:104)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.registerCEPPublisherWithStormMangerService(SiddhiStormOutputEventListener.java:181)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.run(SiddhiStormOutputEventListener.java:128)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
TID: [-1] [] [2015-07-27 04:51:16,890] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error registering CEP publisher with
current manager. Retrying after 5000ms
TID: [-1] [] [2015-07-27 04:51:21,892] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error in registering CEP publisher
for 10.244.28.24:15000 with manager 10.244.28.23:8904. Trying next manager
NotStormManagerException(message:10.244.28.23:8904 not a storm manager)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$registerCEPPublisher_result.read(StormManagerService.java:2116)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.recv_registerCEPPublisher(StormManagerService.java:120)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.registerCEPPublisher(StormManagerService.java:104)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.registerCEPPublisherWithStormMangerService(SiddhiStormOutputEventListener.java:181)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.run(SiddhiStormOutputEventListener.java:128)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
TID: [-1] [] [2015-07-27 04:51:21,895] ERROR
{org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener}
- [-1234:ExecutionPlan:CEP Publisher] Error in registering CEP publisher
for 10.244.28.24:15000 with manager 10.244.3.29:8904. Trying next manager
NotStormManagerException(message:10.244.3.29:8904 not a storm manager)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$registerCEPPublisher_result.read(StormManagerService.java:2116)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.recv_registerCEPPublisher(StormManagerService.java:120)
at
org.wso2.carbon.event.processor.common.storm.manager.service.StormManagerService$Client.registerCEPPublisher(StormManagerService.java:104)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.registerCEPPublisherWithStormMangerService(SiddhiStormOutputEventListener.java:181)
at
org.wso2.carbon.event.processor.core.internal.storm.SiddhiStormOutputEventListener$Registrar.run(SiddhiStormOutputEventListener.java:128)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[3] https://docs.wso2.com/display/CEP400/Clustered+Deployment
[4]
https://docs.wso2.com/display/CEP400/Configuring+WSO2+CEP+to+Run+with+Apache+Storm
Thanks,
--
*Lasindu Charith*
Software Engineer, WSO2 Inc.
Committer & PMC Member, Apache Stratos
Mobile: +94714427192 | Web: blog.lasindu.com
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
