You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@stratos.apache.org by "Pubudu Chinthaka Gunatilaka (JIRA)" <ji...@apache.org> on 2015/11/05 08:15:27 UTC
[jira] [Resolved] (STRATOS-1596) Syncing Failed in CEP 3.1.0 in HA
mode
[ https://issues.apache.org/jira/browse/STRATOS-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pubudu Chinthaka Gunatilaka resolved STRATOS-1596.
--------------------------------------------------
Resolution: Fixed
Fix Version/s: 4.1.5
Fixed with following commit - 28a995e690669ee1e839e7f35430567424f39b28
Fixed restoreState method which is used in window processors to get the current state of the window processor. Current state is the zeroth element of this object.
This issue came across when running cep in HA mode. Another cep fix was done for this in order to support these fixes. In order to run cep 3.1.0 in HA mode, cep patch (1611) should be added.
> Syncing Failed in CEP 3.1.0 in HA mode
> --------------------------------------
>
> Key: STRATOS-1596
> URL: https://issues.apache.org/jira/browse/STRATOS-1596
> Project: Stratos
> Issue Type: Bug
> Affects Versions: 4.1.4
> Reporter: Pubudu Chinthaka Gunatilaka
> Fix For: 4.1.5
>
>
> [1] TID: [0] [CEP] [2015-10-26 11:57:58,639] INFO
> {org.wso2.carbon.event.processor.core.internal.ha.thrift.HAServiceClientThriftImpl}
> - Snapshot received for tenant:-1234 on:AverageInFlightRequestsFinder
> TID: [0] [CEP] [2015-10-26 11:57:58,640] ERROR
> {org.wso2.carbon.event.processor.core.internal.ha.HAManager}
> - Syncing failed when becoming a Passive Node for tenant:-1234 on:AverageInFlightRequestsFinder executi
> on plan
> java.lang.ClassCastException: [Ljava.lang.Object; cannot be cast to java.util.concurrent.LinkedBlockingQueue
> at org.wso2.siddhi.core.util.collection.queue.SiddhiQueue.restoreState(SiddhiQueue.java:48)
> at org.wso2.siddhi.core.query.processor.window.TimeBatchWindowProcessor.restoreState(TimeBatchWindowProcessor.java:148)
> at org.wso2.siddhi.core.query.processor.window.WindowProcessor.restore(WindowProcessor.java:113)
> at org.wso2.siddhi.core.snapshot.SnapshotService.restore(SnapshotService.java:70)
> at org.wso2.siddhi.core.SiddhiManager.restore(SiddhiManager.java:443)
> at org.wso2.carbon.event.processor.core.internal.ha.HAManager.becomePassive(HAManager.java:161)
> at org.wso2.carbon.event.processor.core.internal.ha.HAManager.tryChangeState(HAManager.java:111)
> at org.wso2.carbon.event.processor.core.internal.ha.HAManager.init(HAManager.java:97)
> at org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.addExecutionPlanConfiguration(CarbonEventProcessorService.java:358)
> at org.wso2.carbon.event.processor.core.EventProcessorDeployer.processDeploy(EventProcessorDeployer.java:138)
> at org.wso2.carbon.event.processor.core.internal.util.EventProcessorConfigurationFilesystemInvoker.reload(EventProcessorConfigurationFilesystemInvoker.java:86)
> at org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.activateInactiveExecutionPlanConfigurations(CarbonEventProcessorService.java:749)
> at org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.notifyServiceAvailability(CarbonEventProcessorService.java:530)
> at org.wso2.carbon.event.processor.core.internal.ds.EventProcessorServiceDS.setHazelcastInstance(EventProcessorServiceDS.java:102)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at org.eclipse.equinox.internal.ds.model.ComponentReference.bind(ComponentReference.java:376)
> at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.bindReference(ServiceComponentProp.java:432)
> at org.eclipse.equinox.internal.ds.InstanceProcess.dynamicBind(InstanceProcess.java:416)
> at org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:334)
> at org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:222)
> at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:107)
> at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:861)
> at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:230)
> at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:148)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:819)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:771)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:130)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:214)
> at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:433)
> at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:451)
> at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:950)
> at org.wso2.carbon.core.clustering.hazelcast.HazelcastClusteringAgent.init(HazelcastClusteringAgent.java:214)
> at org.wso2.carbon.core.util.ClusteringUtil.enableClustering(ClusteringUtil.java:44)
> at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:175)
> at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.serviceChanged(StartupFinalizerServiceComponent.java:282)
> at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:107)
> at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:861)
> at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:230)
> at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:148)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:819)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:771)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:130)
> at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:214)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)