CEP Managers are must for Strom based coordination, so use the CEP Managers
to be the carbon cluster as well-known members, else it does not make sense
for CEP deployment. We have also done the testing like that.
Regards
Suho
On Mon, Jul 27, 2015 at 2:16 PM, Lakmal Warusawithana <lak...@wso2.com>
wrote:
>
>
> On Mon, Jul 27, 2015 at 2:15 PM, Lakmal Warusawithana <lak...@wso2.com>
> wrote:
>
>> +1 Azeez
>>
>
> [I mean adding Azeez into the loop]
>
>
>>
>> On Mon, Jul 27, 2015 at 2:07 PM, Lasindu Charith <lasi...@wso2.com>
>> wrote:
>>
>>> 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
>>>
>>
>>
>>
>> --
>> Lakmal Warusawithana
>> Vice President, Apache Stratos
>> Director - Cloud Architecture; WSO2 Inc.
>> Mobile : +94714289692
>> Blog : http://lakmalsview.blogspot.com/
>>
>>
>
>
> --
> Lakmal Warusawithana
> Vice President, Apache Stratos
> Director - Cloud Architecture; WSO2 Inc.
> Mobile : +94714289692
> Blog : http://lakmalsview.blogspot.com/
>
>
--
*S. Suhothayan*
Technical Lead & Team Lead of WSO2 Complex Event Processor
*WSO2 Inc. *http://wso2.com
* <http://wso2.com/>*
lean . enterprise . middleware
*cell: (+94) 779 756 757 | blog: http://suhothayan.blogspot.com/
<http://suhothayan.blogspot.com/>twitter: http://twitter.com/suhothayan
<http://twitter.com/suhothayan> | linked-in:
http://lk.linkedin.com/in/suhothayan <http://lk.linkedin.com/in/suhothayan>*
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
