[STRATOS-1596] Syncing Failed in CEP 3.1.0 in HA mode

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 4.1.4
• Fix Version/s: 4.1.5
• Assignee: Unassigned
• Reporter: Pubudu Chinthaka Gunatilaka
• Created: 04/Nov/15 05:35
• Updated: 05/Nov/15 07:14
• Resolved: 05/Nov/15 07:14

Description

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