Re: [rules-users] Expiry of events not occurring for sliding window

I'll preface this by saying this may not be the correct way to do this, so suggestions welcome... For this example, the name can be something like 'collector1', 'collector2'. For each collector, there are normalized stats, like 'CPU', 'IO', etc. <pre> // Imports and other stuff declare InstanceHealth @role(event) @expires(10s) @timestamp(timeStamp) end rule "Iostats above 90 over 5 seconds" when $mih:InstanceHealth($id:id, $luid:name, $stat:stat ) from entry-point "stat-stream" $measure : Number( doubleValue > 90 ) from accumulate( InstanceHealth( $inst:name==$luid, $value:value, stat==$stat) over window:time( 5s ) from entry-point "stat-stream", average($value)) then logger.warn( "--------Average--------------" ); logger.warn( $mih.hashCode() + " // "+$stat +" // "+$id+" : "+$luid +" == "+$measure ); // doStuff based upon the name and stat end rule "Log instance" when $m:InstanceHealth($id:id, $stat:stat, $inst:name, $v:value ) from entry-point "stat-stream" then logger.warn( "------------Instance--------------" ); logger.warn( "--"+$inst+" == "+$stat +" value = "+$v ); end </pre> So the 'Iostats above 90 over 5 seconds' rule is trying to match up stats with collectors so there are no cross-products (stats aren't accumulated across collectors and each stat type gets it's own evaluation). This actually seems to be working, except the InstanceHealth objects don't seem to be being evicted and I'm apparently getting multiple activations (?). Note when I remove the line w/ the $mih binding, things get evicted fine but I don't have access to the name, stat, etc. TIA. A snippet of a log (I can confirm that three different iostats were inserted for collector2) ==>[ObjectInsertedEventImpl: getFactHandle()=1:19:1003982845:1003982845:19:stat-stream, getObject()=com.poc.mediator.domain.InstanceHealth : null, getKnowledgeRuntime()=org.drools.impl.StatefulKnowledgeSessionImpl@30a2268a , getPropagationContext()=PropagationContextImpl [activeActivations=0, dormantActivations=15, entryPoint=EntryPoint::stat-stream, factHandle=1:19:1003982845:1003982845:19:stat-stream, leftTuple=null, originOffset=-1, propagationNumber=13, rule=null, type=0]] 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - 1302111244 // iostats // null : collector2 == 91.0 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - 158787804 // iostats // null : collector2 == 91.0 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:16,004 [Rule-Execution-Thread] WARN WorkingMemory - 1785305512 // iostats // null : collector2 == 91.0 ==>[ObjectInsertedEventImpl: getFactHandle()=1:21:1340153218:1340153218:21:stat-stream, getObject()=com.poc.mediator.domain.InstanceHealth : null, getKnowledgeRuntime()=org.drools.impl.StatefulKnowledgeSessionImpl@30a2268a , getPropagationContext()=PropagationContextImpl [activeActivations=0, dormantActivations=20, entryPoint=EntryPoint::stat-stream, factHandle=1:21:1340153218:1340153218:21:stat-stream, leftTuple=null, originOffset=-1, propagationNumber=16, rule=null, type=0]] 2011-09-23 11:35:16,100 [Insertion Thread] INFO mediator.RulesExecutionService - inserting com.poc.mediator.domain.InstanceHealth : null... 2011-09-23 11:35:16,101 [Insertion Thread] WARN mediator.RulesExecutionService - >>><org.drools.event.rule.impl.ObjectInsertedEventImpl@1dddec9e factHandle=1:21:1340153218:1340153218:21:stat-stream object=com.poc.mediator.domain.InstanceHealth : null kruntime=org.drools.impl.StatefulKnowledgeSessionImpl@30a2268a propagationContext=PropagationContextImpl [activeActivations=0, dormantActivations=20, entryPoint=EntryPoint::stat-stream, factHandle=1:21:1340153218:1340153218:21:stat-stream, leftTuple=null, originOffset=-1, propagationNumber=16, rule=null, type=0]> 2011-09-23 11:35:16,101 [Insertion Thread] INFO mediator.RulesExecutionService - ...done inserting <com.poc.mediator.domain.InstanceHealth@4fe11d82 timeStamp=Fri Sep 23 11:35:16 CDT 2011 stat=cpu value=88.0 id=null version=null Instance=com.poc.mediator.domain.Instance : null> 2011-09-23 11:35:16,108 [Insertion Thread] INFO mediator.RulesExecutionService - inserting com.poc.mediator.domain.InstanceHealth : null... 2011-09-23 11:35:16,109 [Insertion Thread] WARN mediator.RulesExecutionService - >>><org.drools.event.rule.impl.ObjectInsertedEventImpl@56300388 factHandle=1:23:1092542236:1092542236:23:stat-stream object=com.poc.mediator.domain.InstanceHealth : null kruntime=org.drools.impl.StatefulKnowledgeSessionImpl@30a2268a propagationContext=PropagationContextImpl [activeActivations=2, dormantActivations=19, entryPoint=EntryPoint::stat-stream, factHandle=1:23:1092542236:1092542236:23:stat-stream, leftTuple=null, originOffset=-1, propagationNumber=17, rule=null, type=0]> 2011-09-23 11:35:16,109 [Insertion Thread] INFO mediator.RulesExecutionService - ...done inserting <com.poc.mediator.domain.InstanceHealth@411edf1c timeStamp=Fri Sep 23 11:35:16 CDT 2011 stat=iostats value=85.0 id=null version=null Instance=com.poc.mediator.domain.Instance : null> ==>[ObjectInsertedEventImpl: getFactHandle()=1:23:1092542236:1092542236:23:stat-stream, getObject()=com.poc.mediator.domain.InstanceHealth : null, getKnowledgeRuntime()=org.drools.impl.StatefulKnowledgeSessionImpl@30a2268a , getPropagationContext()=PropagationContextImpl [activeActivations=2, dormantActivations=19, entryPoint=EntryPoint::stat-stream, factHandle=1:23:1092542236:1092542236:23:stat-stream, leftTuple=null, originOffset=-1, propagationNumber=17, rule=null, type=0]] 2011-09-23 11:35:16,160 [Rule-Execution-Thread] WARN WorkingMemory - ------------Instance-------------- 2011-09-23 11:35:16,161 [Rule-Execution-Thread] WARN WorkingMemory - --collector1 == iostats value = 85.0 2011-09-23 11:35:16,161 [Rule-Execution-Thread] WARN WorkingMemory - ------------Instance-------------- 2011-09-23 11:35:16,161 [Rule-Execution-Thread] WARN WorkingMemory - --collector2 == cpu value = 88.0 2011-09-23 11:35:17,013 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:17,014 [Rule-Execution-Thread] WARN WorkingMemory - 1302111244 // iostats // null : collector2 == 92.0 2011-09-23 11:35:17,014 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:17,014 [Rule-Execution-Thread] WARN WorkingMemory - 158787804 // iostats // null : collector2 == 92.0 2011-09-23 11:35:17,014 [Rule-Execution-Thread] WARN WorkingMemory - --------Average-------------- 2011-09-23 11:35:17,014 [Rule-Execution-Thread] WARN WorkingMemory - 1785305512 // iostats // null : collector2 == 92.0 -- View this message in context: http://drools.46999.n3.nabble.com/Expiry-of-events-not-occurring-for-slid... Sent from the Drools: User forum mailing list archive at Nabble.com. _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users