Aled Sage created BROOKLYN-569:
----------------------------------

             Summary: Aggregator enricher lost on rebind (due to 
ClassCastException)
                 Key: BROOKLYN-569
                 URL: https://issues.apache.org/jira/browse/BROOKLYN-569
             Project: Brooklyn
          Issue Type: Bug
            Reporter: Aled Sage


I had an aggregator for {{systemload.average}} on the cluster. On rebind, it 
failed with the {{ClassCastException}} shown below. The consequence (I think?) 
is that the enricher is not added to the entity.

{noformat}
2017-10-17T10:37:37,748 WARN  122 o.a.b.e.s.Aggregator [FelixStartLevel] Error 
calculating and setting aggregate for enricher 
Aggregator{name=org.apache.brooklyn.enricher.stock.Aggregator, running=true, 
entity=DynamicClusterImpl{id=pp5qg4p26r}, id=y9jnikf9in}
java.lang.ClassCastException: java.lang.String cannot be cast to 
java.lang.Number
        at 
org.apache.brooklyn.enricher.stock.MathAggregatorFunctions$BasicComputingNumber.apply(MathAggregatorFunctions.java:121)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.MathAggregatorFunctions$BasicComputingNumber.apply(MathAggregatorFunctions.java:110)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.Aggregator.compute(Aggregator.java:252) 
~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.Aggregator.onUpdated(Aggregator.java:239) 
~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.AbstractAggregator.setEntity(AbstractAggregator.java:147)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.entity.AbstractEntity$BasicEnricherSupport.add(AbstractEntity.java:1686)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.BasicEntityRebindSupport.addEnrichers(BasicEntityRebindSupport.java:140)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.BasicEntityRebindSupport.addEnrichers(BasicEntityRebindSupport.java:55)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindIteration.associateAdjunctsWithEntities(RebindIteration.java:681)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindIteration.doRun(RebindIteration.java:258)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.InitialFullRebindIteration.doRun(InitialFullRebindIteration.java:69)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindIteration.run(RebindIteration.java:280)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindManagerImpl.rebindImpl(RebindManagerImpl.java:538)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindManagerImpl.lambda$rebind$0(RebindManagerImpl.java:494)
 ~[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.util.core.task.BasicExecutionContext$1.call(BasicExecutionContext.java:143)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.util.core.task.BasicExecutionContext$1.call(BasicExecutionContext.java:141)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.util.core.task.BasicExecutionContext.runInSameThread(BasicExecutionContext.java:227)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.util.core.task.BasicExecutionContext.get(BasicExecutionContext.java:141)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.rebind.RebindManagerImpl.rebind(RebindManagerImpl.java:493)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.launcher.common.BasicLauncher.startPersistenceWithoutHA(BasicLauncher.java:649)
 [126:org.apache.brooklyn.launcher-common:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.launcher.common.BasicLauncher.startPersistence(BasicLauncher.java:611)
 [126:org.apache.brooklyn.launcher-common:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.launcher.common.BasicLauncher.handlePersistence(BasicLauncher.java:501)
 [126:org.apache.brooklyn.launcher-common:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.launcher.common.BasicLauncher.startPartTwo(BasicLauncher.java:418)
 [126:org.apache.brooklyn.launcher-common:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.launcher.osgi.OsgiLauncherImpl.startOsgi(OsgiLauncherImpl.java:116)
 [333:org.apache.brooklyn.karaf-init:1.0.0.SNAPSHOT]
        at Proxy15e05ead_d753_4d2d_a439_dc3559cde5b4.startOsgi(Unknown Source) 
[?:?]
        at 
org.apache.brooklyn.launcher.osgi.start.OsgiLauncherCompleter.init(OsgiLauncherCompleter.java:36)
 [335:org.apache.brooklyn.karaf-start:1.0.0.SNAPSHOT]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
~[?:?]
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 ~[?:?]
        at java.lang.reflect.Method.invoke(Method.java:498) ~[?:?]
        at 
org.apache.aries.blueprint.utils.ReflectionUtils.invoke(ReflectionUtils.java:299)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BeanRecipe.invoke(BeanRecipe.java:980) 
[15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BeanRecipe.runBeanProcInit(BeanRecipe.java:736)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BeanRecipe.internalCreate2(BeanRecipe.java:848)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BeanRecipe.internalCreate(BeanRecipe.java:811)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.di.AbstractRecipe$1.call(AbstractRecipe.java:79) 
[15:org.apache.aries.blueprint.core:1.8.2]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:?]
        at 
org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:88) 
[15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintRepository.createInstances(BlueprintRepository.java:255)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintRepository.createAll(BlueprintRepository.java:186)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintContainerImpl.instantiateEagerComponents(BlueprintContainerImpl.java:704)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintContainerImpl.doRun(BlueprintContainerImpl.java:410)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintContainerImpl.run(BlueprintContainerImpl.java:275)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:300)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:269)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:265)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.blueprint.container.BlueprintExtender.modifiedBundle(BlueprintExtender.java:255)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.customizerModified(BundleHookBundleTracker.java:500)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.customizerModified(BundleHookBundleTracker.java:433)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.util.tracker.hook.BundleHookBundleTracker$AbstractTracked.track(BundleHookBundleTracker.java:725)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.bundleChanged(BundleHookBundleTracker.java:463)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.aries.util.tracker.hook.BundleHookBundleTracker$BundleEventHook.event(BundleHookBundleTracker.java:422)
 [15:org.apache.aries.blueprint.core:1.8.2]
        at 
org.apache.felix.framework.util.SecureAction.invokeBundleEventHook(SecureAction.java:1179)
 [?:?]
        at 
org.apache.felix.framework.EventDispatcher.createWhitelistFromHooks(EventDispatcher.java:730)
 [?:?]
        at 
org.apache.felix.framework.EventDispatcher.fireBundleEvent(EventDispatcher.java:485)
 [?:?]
        at org.apache.felix.framework.Felix.fireBundleEvent(Felix.java:4563) 
[?:?]
        at org.apache.felix.framework.Felix.startBundle(Felix.java:2173) [?:?]
        at 
org.apache.felix.framework.Felix.setActiveStartLevel(Felix.java:1372) [?:?]
        at 
org.apache.felix.framework.FrameworkStartLevelImpl.run(FrameworkStartLevelImpl.java:308)
 [?:?]
        at java.lang.Thread.run(Thread.java:748) [?:?]
{noformat}

Looking earlier in the log, the enricher logged errors about 
{{ClassCastException}} when getting these values:

{noformat}
2017-10-17T09:36:32,175 DEBUG 122 b.SSH [r-ZF3eryKq-46157] ssh-feed, on machine 
SshMachineLocation[34.241.80.46:[email protected]/34.241.80.46:22(id=e8oofbfbv4)],
 completed: return st
atus 0
2017-10-17T09:36:32,176 WARN  122 o.a.b.e.s.Aggregator [r-ZF3eryKq-46162] Error 
calculating and setting aggregate for enricher Aggregator{running=true, 
entity=DynamicClusterImpl{id=pp5qg4p26r}, id=y9jnikf9in}
java.lang.ClassCastException: java.lang.String cannot be cast to 
java.lang.Number
        at 
org.apache.brooklyn.enricher.stock.MathAggregatorFunctions$BasicComputingNumber.apply(MathAggregatorFunctions.java:121)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.MathAggregatorFunctions$BasicComputingNumber.apply(MathAggregatorFunctions.java:110)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.Aggregator.compute(Aggregator.java:252) 
[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.Aggregator.onUpdated(Aggregator.java:239) 
[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.enricher.stock.Aggregator.onEvent(Aggregator.java:233) 
[122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.core.mgmt.internal.LocalSubscriptionManager$1.run(LocalSubscriptionManager.java:345)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:?]
        at 
org.apache.brooklyn.util.core.task.BasicExecutionManager$SubmissionCallable.call(BasicExecutionManager.java:565)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at 
org.apache.brooklyn.util.core.task.SingleThreadedScheduler$1.call(SingleThreadedScheduler.java:116)
 [122:org.apache.brooklyn.core:1.0.0.SNAPSHOT]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:?]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:?]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:?]
        at java.lang.Thread.run(Thread.java:748) [?:?]
{noformat}

The child entity's persisted state has 
{{<systemload.average>0.36</systemload.average>}}, but the value {{0.36}} is of 
type string.




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to