[
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)
