Hi All, I want to test how ML extension can be integrated with CEP storm distributed cluster. So for that I have set up CEP with a manager node and a worker node. And installed ML features using p2-repository in manager node. Then deployed an event flow in CEP manager node and send events to the receiver in worker node. Then I observed " No extension exist for StreamFunctionExtension{namespace='ml'} in execution plan "ExecutionPlanML" in worker node.
To overcome this issue, I have started worker node without "-DworkerNode=true" argument and installed ML features in worker node as well. Then restart the entire cluster (worker started with -DworkerNode=true) and send events to the worker node. But events are not logged in worker node (logger publisher is used). Further I have tested the same flow in standalone CEP pack according to the instructions given in [1] <https://docs.wso2.com/display/CEP400/Predictive+Analytics+with+WSO2+Machine+Learner> , and it works as expected. [1] https://docs.wso2.com/display/CEP400/Predictive+Analytics+with+WSO2+Machine+Learner Please help me to clarify below issues 1) When we setup a storm distributed cluster and installed a feature in manager node, isn't there any way of synchronizing that feature details with worker node rather than installing the same features in worker node? 2) Even after I installed the feature in worker node I didn't get any events. What can be the possible reasons for that? Since there are no documentation on how to set up the ML extension in CEP storm distribute cluster , it would be better to update the documents with relevant details. Appreciate your help on this matter. Thanks -- *Sashika WijesingheSoftware Engineer - QA Team* Mobile : +94 (0) 774537487 sash...@wso2.com
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev