[rules-users] Drools Fusion inconsistencies at increasing event throughputs
Mark Proctor
mproctor at codehaus.org
Fri Mar 28 11:57:22 EDT 2014
we’ve being auditing the code here, and we’ve found an issue on what happens when a rule is re-matched and the timer updated. Mario is addressing this now, and also re-viewing dropping of output. He’ll post with an update soon.
Mark
On 25 Mar 2014, at 16:09, Vieri <vieri.emiliani at gmail.com> wrote:
> First of all, thanks for the support.
> Mario, I confirm that the case you provided works fine also at my side. Still, have you tried my first example (using the cron directly to the counting rule)? Can you confirm it is not working, since this was my first concern?
> As I said in the previous post, using the CronTrigger pattern greatly improves stability (I managed to run it at 500 eps), but it is not resolutive.
> Adding a few rules, it's enough to go back to instability.
>
>
> Here's the complete test case.
> Basically, a SynthEvent is created with the meta list populated randomly with up to 4 values picked from a list of 10 strings ("one" to "ten").
> For each meta value an Entity object is created (for enumeration purposes).
> Then, rules generate metrics for both events (every 10s) and meta (every 60s).
> Test is ran at 300 events per second +/- 20% (our real use case is closer to some hundreds events per second than some tens).
>
> First of all, the full SynthEvent class:
>
> package it.intext.unity.test;
>
> import java.util.Arrays;
> import java.util.Date;
> import java.util.List;
>
> public class SynthEvent {
>
> long id;
> Date timestamp;
> List<String> meta;
>
> public long getId() {
> return id;
> }
> public void setId(long id) {
> this.id = id;
> }
>
> public Date getTimestamp() {
> return timestamp;
> }
> public void setTimestamp(Date timestamp) {
> this.timestamp = timestamp;
> }
>
> public List<String> getMeta() {
> return meta;
> }
> public void setMeta(List<String> meta) {
> this.meta = meta;
> }
>
> public SynthEvent() {
> super();
> }
>
> @Override
> public String toString() {
> StringBuilder builder = new StringBuilder();
> builder.append("SynthEvent [id=");
> builder.append(id);
> builder.append(", timestamp=");
> builder.append(timestamp);
> builder.append(", meta=");
> builder.append(meta);
> builder.append("]");
> return builder.toString();
> }
> public String toString() {
> StringBuilder builder = new StringBuilder();
> builder.append("SynthEvent [id=");
> builder.append(id);
> builder.append(", timestamp=");
> builder.append(timestamp);
> builder.append(", meta=");
> builder.append(meta);
> builder.append("]");
> return builder.toString();
> }
>
> }
>
> Here's the feeding part of the test class:
>
> private void process(final KieSession session) {
> new Thread(){
> public void run() {
> session.fireUntilHalt();
> };
> }.start();
> }
>
>
> private void feed(final KieSession session) {
> new Thread(){
> public void run() {
> try {
> int counter = 0;
> while(true) {
> counter++;
> session.getEntryPoint("synth").insert(createEvent());
> Thread.sleep(getSleepRate());
> if ((counter % 1000) == 0) {
> logger.debug("Total events: {}", counter);
> }
> }
> } catch (InterruptedException e) {
> logger.warn("{}", e);
> }
> };
> }.start();
> }
>
> static final int eventThroughput = 300;
> static final double variance = 0.2;
>
> protected long getSleepRate() {
> return (long) (1000.0 / (eventThroughput * ((1.0 - variance) + Math.random() * variance * 2)));
> }
>
> protected SynthEvent createEvent() {
> SynthEvent ret = new SynthEvent();
> ret.setId(System.currentTimeMillis());
> ret.setTimestamp(new Date());
> ret.setMeta(createMeta());
> return ret;
> }
>
> static final List<String> metas = Arrays.asList("one", "two", "three", "four", "five", "six", "seven", "eight", "nine", "ten");
> static final int maxMeta = 4;
> static final int metaSize = metas.size();
>
> protected List<String> createMeta() {
> List<String> ret = new ArrayList<String>();
> int nofItems = (int) (Math.random() * maxMeta);
> for (int i=0; i<nofItems; i++) {
> ret.add(metas.get((int) (Math.random() * metaSize)));
> }
> return ret;
> }
>
>
> And here's the drl, using the CronTrigger pattern:
>
> package it.intext.unity.test
>
> import it.intext.unity.test.SynthEvent;
>
> import java.util.Date;
>
> global org.slf4j.Logger logger;
>
> declare SynthEvent
> @role( event )
> @timestamp( timestamp )
> end
>
> declare EventCounter
> @role( event )
> @timestamp( timestamp )
> id : long
> key : String
> timestamp : Date
> end
>
> declare CronTrigger
> @role( event )
> @timestamp( timestamp )
> interval : String
> timestamp : Date
> end
>
> declare MetricRequest
> metric : String
> end
>
> declare Subscription
> key : String
> interval : String
> end
>
>
> declare Entity
> key : String
> end
>
> // Setup rules
> rule "Create subscriptions"
> when
> then
> insert( new Subscription("epm", "10s") );
> end
>
> rule "Create meta subscriptions 60s"
> when
> Entity( $key : key )
> then
> insert( new Subscription($key, "60s") );
> end
>
> // Cron management
>
> rule "Cron trigger 10s"
> timer ( cron: 0/10 * * * * ? )
> when
> then
> entryPoints["triggers"].insert( new CronTrigger( "10s", new Date() ) );
> end
>
> rule "Cron trigger 60s"
> timer ( cron: 0/60 * * * * ? )
> when
> then
> entryPoints["triggers"].insert( new CronTrigger( "60s", new Date() ) );
> end
>
> rule "Subscription"
> when
> CronTrigger( $interval := interval ) from entry-point "triggers"
> Subscription( $interval := interval, $key : key )
> then
> entryPoints["requests"].insert( new MetricRequest($key) );
> end
>
> // Business rules
> rule "Create counter"
> when
> $e : SynthEvent() from entry-point "synth"
> then
> entryPoints["counters"].insert( new EventCounter( $e.getId(), "event", $e.getTimestamp() ) );
> end
>
> rule "Create meta counter"
> when
> $e : SynthEvent() from entry-point "synth"
> $meta : String( ) from $e.getMeta()
> then
> entryPoints["counters"].insert( new EventCounter( $e.getId(), $meta, $e.getTimestamp() ) );
> end
>
> rule "Create meta"
> when
> $e : SynthEvent() from entry-point "synth"
> $meta : String( ) from $e.getMeta()
> not( Entity( key == $meta ) )
> then
> insert( new Entity($meta) );
> end
>
>
> rule "Count epm"
> when
> $req : MetricRequest( metric == "epm" ) from entry-point "requests"
> Number( $count : intValue ) from accumulate(
> EventCounter( key == "event" ) over window:time( 60s ) from entry-point "counters", count(1) )
> then
> logger.debug("epm = {}", $count );
> retract( $req );
> end
>
>
> rule "Count meta"
> when
> $req : MetricRequest( $key := metric ) from entry-point "requests"
> Number( $count : intValue ) from accumulate(
> EventCounter( $key := key ) over window:time( 60s ) from entry-point "counters", count(1) )
> then
> logger.debug("{} = {}", $key, $count );
> retract( $req );
> end
>
>
>
> Here's the log of a quick-failing run:
>
> [DEBUG] 2014-03-25 16:28:04.769 (StreamTester.java:run:68) Total events: 1000
> [DEBUG] 2014-03-25 16:28:07.774 (StreamTester.java:run:68) Total events: 2000
> [DEBUG] 2014-03-25 16:28:10.100 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 2769
> [DEBUG] 2014-03-25 16:28:10.723 (StreamTester.java:run:68) Total events: 3000
> [DEBUG] 2014-03-25 16:28:13.681 (StreamTester.java:run:68) Total events: 4000
> [DEBUG] 2014-03-25 16:28:16.668 (StreamTester.java:run:68) Total events: 5000
> [DEBUG] 2014-03-25 16:28:19.541 (StreamTester.java:run:68) Total events: 6000
> [DEBUG] 2014-03-25 16:28:20.054 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 6164
> [DEBUG] 2014-03-25 16:28:22.421 (StreamTester.java:run:68) Total events: 7000
> [DEBUG] 2014-03-25 16:28:25.336 (StreamTester.java:run:68) Total events: 8000
> [DEBUG] 2014-03-25 16:28:28.217 (StreamTester.java:run:68) Total events: 9000
> [DEBUG] 2014-03-25 16:28:30.030 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 9627
> [DEBUG] 2014-03-25 16:28:31.088 (StreamTester.java:run:68) Total events: 10000
> [DEBUG] 2014-03-25 16:28:33.968 (StreamTester.java:run:68) Total events: 11000
> [DEBUG] 2014-03-25 16:28:36.904 (StreamTester.java:run:68) Total events: 12000
> [DEBUG] 2014-03-25 16:28:39.782 (StreamTester.java:run:68) Total events: 13000
> [DEBUG] 2014-03-25 16:28:40.024 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 13077
> [DEBUG] 2014-03-25 16:28:42.736 (StreamTester.java:run:68) Total events: 14000
> [DEBUG] 2014-03-25 16:28:45.615 (StreamTester.java:run:68) Total events: 15000
> [DEBUG] 2014-03-25 16:28:48.459 (StreamTester.java:run:68) Total events: 16000
> [DEBUG] 2014-03-25 16:28:50.030 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 16538
> [DEBUG] 2014-03-25 16:28:51.412 (StreamTester.java:run:68) Total events: 17000
> [DEBUG] 2014-03-25 16:28:54.293 (StreamTester.java:run:68) Total events: 18000
> [DEBUG] 2014-03-25 16:28:57.549 (StreamTester.java:run:68) Total events: 19000
> [DEBUG] 2014-03-25 16:29:00.021 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 19860
> [DEBUG] 2014-03-25 16:29:00.211 (Rule_Count_meta1429890510.java:defaultConsequence:14) two = 2972
> [DEBUG] 2014-03-25 16:29:00.214 (Rule_Count_meta1429890510.java:defaultConsequence:14) eight = 3099
> [DEBUG] 2014-03-25 16:29:00.215 (Rule_Count_meta1429890510.java:defaultConsequence:14) ten = 3008
> [DEBUG] 2014-03-25 16:29:00.215 (Rule_Count_meta1429890510.java:defaultConsequence:14) three = 2982
> [DEBUG] 2014-03-25 16:29:00.216 (Rule_Count_meta1429890510.java:defaultConsequence:14) six = 3006
> [DEBUG] 2014-03-25 16:29:00.216 (Rule_Count_meta1429890510.java:defaultConsequence:14) five = 2959
> [DEBUG] 2014-03-25 16:29:00.217 (Rule_Count_meta1429890510.java:defaultConsequence:14) one = 2934
> [DEBUG] 2014-03-25 16:29:00.217 (Rule_Count_meta1429890510.java:defaultConsequence:14) seven = 3013
> [DEBUG] 2014-03-25 16:29:00.218 (Rule_Count_meta1429890510.java:defaultConsequence:14) four = 2973
> [DEBUG] 2014-03-25 16:29:00.218 (Rule_Count_meta1429890510.java:defaultConsequence:14) nine = 3012
> [DEBUG] 2014-03-25 16:29:00.510 (StreamTester.java:run:68) Total events: 20000
> [DEBUG] 2014-03-25 16:29:03.671 (StreamTester.java:run:68) Total events: 21000
> [DEBUG] 2014-03-25 16:29:06.798 (StreamTester.java:run:68) Total events: 22000
> [DEBUG] 2014-03-25 16:29:09.969 (StreamTester.java:run:68) Total events: 23000
> [DEBUG] 2014-03-25 16:29:10.045 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 20242
> [DEBUG] 2014-03-25 16:29:13.362 (StreamTester.java:run:68) Total events: 24000
> [DEBUG] 2014-03-25 16:29:16.352 (StreamTester.java:run:68) Total events: 25000
> [DEBUG] 2014-03-25 16:29:19.400 (StreamTester.java:run:68) Total events: 26000
> [DEBUG] 2014-03-25 16:29:20.849 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 20029
> [DEBUG] 2014-03-25 16:29:22.795 (StreamTester.java:run:68) Total events: 27000
> [DEBUG] 2014-03-25 16:29:25.785 (StreamTester.java:run:68) Total events: 28000
> [DEBUG] 2014-03-25 16:29:28.855 (StreamTester.java:run:68) Total events: 29000
> [DEBUG] 2014-03-25 16:29:30.018 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 18647
> [DEBUG] 2014-03-25 16:29:31.858 (StreamTester.java:run:68) Total events: 30000
> [DEBUG] 2014-03-25 16:29:34.983 (StreamTester.java:run:68) Total events: 31000
> [DEBUG] 2014-03-25 16:29:37.947 (StreamTester.java:run:68) Total events: 32000
> [DEBUG] 2014-03-25 16:29:40.011 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 15201
> [DEBUG] 2014-03-25 16:29:40.928 (StreamTester.java:run:68) Total events: 33000
> [DEBUG] 2014-03-25 16:29:43.920 (StreamTester.java:run:68) Total events: 34000
> [DEBUG] 2014-03-25 16:29:46.911 (StreamTester.java:run:68) Total events: 35000
> [DEBUG] 2014-03-25 16:29:50.011 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 11740
> [DEBUG] 2014-03-25 16:29:50.023 (StreamTester.java:run:68) Total events: 36000
> [DEBUG] 2014-03-25 16:29:52.998 (StreamTester.java:run:68) Total events: 37000
> [DEBUG] 2014-03-25 16:29:55.925 (StreamTester.java:run:68) Total events: 38000
> [DEBUG] 2014-03-25 16:29:58.845 (StreamTester.java:run:68) Total events: 39000
> [DEBUG] 2014-03-25 16:30:00.009 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 8417
> [DEBUG] 2014-03-25 16:30:00.038 (Rule_Count_meta1429890510.java:defaultConsequence:14) two = 2606
> [DEBUG] 2014-03-25 16:30:00.039 (Rule_Count_meta1429890510.java:defaultConsequence:14) eight = 2534
> [DEBUG] 2014-03-25 16:30:00.039 (Rule_Count_meta1429890510.java:defaultConsequence:14) ten = 2763
> [DEBUG] 2014-03-25 16:30:00.040 (Rule_Count_meta1429890510.java:defaultConsequence:14) three = 2623
> [DEBUG] 2014-03-25 16:30:00.040 (Rule_Count_meta1429890510.java:defaultConsequence:14) six = 2641
> [DEBUG] 2014-03-25 16:30:00.040 (Rule_Count_meta1429890510.java:defaultConsequence:14) five = 2579
> [DEBUG] 2014-03-25 16:30:00.040 (Rule_Count_meta1429890510.java:defaultConsequence:14) one = 2690
> [DEBUG] 2014-03-25 16:30:00.041 (Rule_Count_meta1429890510.java:defaultConsequence:14) seven = 2698
> [DEBUG] 2014-03-25 16:30:00.041 (Rule_Count_meta1429890510.java:defaultConsequence:14) four = 2658
> [DEBUG] 2014-03-25 16:30:00.041 (Rule_Count_meta1429890510.java:defaultConsequence:14) nine = 2669
> [DEBUG] 2014-03-25 16:30:01.735 (StreamTester.java:run:68) Total events: 40000
> [DEBUG] 2014-03-25 16:30:04.682 (StreamTester.java:run:68) Total events: 41000
> [DEBUG] 2014-03-25 16:30:07.604 (StreamTester.java:run:68) Total events: 42000
> [DEBUG] 2014-03-25 16:30:10.011 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 5266
> [DEBUG] 2014-03-25 16:30:10.622 (StreamTester.java:run:68) Total events: 43000
> [DEBUG] 2014-03-25 16:30:13.493 (StreamTester.java:run:68) Total events: 44000
> [DEBUG] 2014-03-25 16:30:16.383 (StreamTester.java:run:68) Total events: 45000
> [DEBUG] 2014-03-25 16:30:19.263 (StreamTester.java:run:68) Total events: 46000
> [DEBUG] 2014-03-25 16:30:20.012 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 2078
> [DEBUG] 2014-03-25 16:30:22.146 (StreamTester.java:run:68) Total events: 47000
> [DEBUG] 2014-03-25 16:30:25.036 (StreamTester.java:run:68) Total events: 48000
> [DEBUG] 2014-03-25 16:30:27.911 (StreamTester.java:run:68) Total events: 49000
> [DEBUG] 2014-03-25 16:30:30.003 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 0
> [DEBUG] 2014-03-25 16:30:30.800 (StreamTester.java:run:68) Total events: 50000
>
> At 250 eps it took about 56K events (3'30") to hang (short log below)
>
> [DEBUG] 2014-03-25 16:37:20.013 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 16084
> [DEBUG] 2014-03-25 16:37:23.222 (StreamTester.java:run:68) Total events: 52000
> [DEBUG] 2014-03-25 16:37:26.751 (StreamTester.java:run:68) Total events: 53000
> [DEBUG] 2014-03-25 16:37:30.069 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 16085
> [DEBUG] 2014-03-25 16:37:30.510 (StreamTester.java:run:68) Total events: 54000
> [DEBUG] 2014-03-25 16:37:34.099 (StreamTester.java:run:68) Total events: 55000
> [DEBUG] 2014-03-25 16:37:37.701 (StreamTester.java:run:68) Total events: 56000
> [DEBUG] 2014-03-25 16:37:40.014 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 15381
> [DEBUG] 2014-03-25 16:37:41.381 (StreamTester.java:run:68) Total events: 57000
> [DEBUG] 2014-03-25 16:37:44.977 (StreamTester.java:run:68) Total events: 58000
> [DEBUG] 2014-03-25 16:37:48.632 (StreamTester.java:run:68) Total events: 59000
> [DEBUG] 2014-03-25 16:37:50.011 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 12677
> [DEBUG] 2014-03-25 16:37:52.343 (StreamTester.java:run:68) Total events: 60000
> [DEBUG] 2014-03-25 16:37:55.958 (StreamTester.java:run:68) Total events: 61000
> [DEBUG] 2014-03-25 16:37:59.546 (StreamTester.java:run:68) Total events: 62000
> [DEBUG] 2014-03-25 16:38:00.009 (Rule_Count_epm701941061.java:defaultConsequence:14) epm = 10033
>
> At 200 eps the system hanged after 185K events (more than 16 minutes).
>
> More realish examples (e.g. counting how many distinct tweets get at least one retweet [far less than 10%, BTW]) hang in less than 10 minutes even at 20 events per second or less.
>
> Hope this helps. Please guys, ask me for more details at any moment.
> I would be definitely glad to solve this issue and to go on with our Drools Fusion roadmap ;)
> Thanks in advance,
> Vieri
>
>
>
> On 25 March 2014 14:09, Mario Fusco <mario.fusco at gmail.com> wrote:
> Hi,
>
> I am trying to reproduce the issue you reported, but so far I couldn't. This
> is drl I am using:
>
> import org.drools.test.SynthEvent
> import java.util.Date
>
> declare SynthEvent
> @role( event )
> @timestamp( timestamp )
> end
>
> declare EventCounter
> @role( event )
> @timestamp( timestamp )
> id : long
> key : String
> timestamp : Date
> end
>
> declare CronTrigger end
>
> rule "Trigger Metric"
> timer ( cron: 0/10 * * * * ? )\n
> when
> then
> entryPoints["triggers"].insert( new CronTrigger() );
> end
>
> rule "Create counter"
> when
> $e : SynthEvent() from entry-point "synth"
> then
> entryPoints["counters"].insert(new EventCounter( $e.getId(), "event",
> $e.getTimestamp() ) );
> end
>
> rule "Count epm"
> when
> $trigger : CronTrigger() from entry-point "triggers"
> Number( $count : intValue ) from accumulate(
> EventCounter( key == "event" ) over window:time( 60s )from entry-point
> "counters", count(1) )
> then
> System.out.println("[" + new Date() + "] epm = " + $count );
> retract($trigger);
> end
>
> and this is how I am using it:
>
> final KieSession ksession = kbase.newKieSession();
> EntryPoint synthEP = ksession.getEntryPoint("synth");
>
> new Thread(){
> public void run() {
> ksession.fireUntilHalt();
> };
> }.start();
>
> long counter = 0;
> while(true) {
> counter++;
> synthEP.insert(new SynthEvent(counter));
> try {
> Thread.sleep(20L);
> } catch (InterruptedException e) {
> throw new RuntimeException(e);
> }
> if ((counter % 1000) == 0) {
> System.out.println("Total events: " + counter);
> }
> }
>
> Note that since you mentioned you expected around 3K events per minute I am
> doing a sleep of 20 msec between the insertion of 2 consecutive events. Is
> that correct?
>
> I let this run for 10 minutes and I got the output I am pasting at the end
> of this email, so I think that it is working as expected. Please let me know
> if you'll give a try at my test case and if it works correctly also for you.
> Also if you find any further problem feel free to send a reproducer so I
> could give it a try.
>
> Regards,
> Mario
>
> [Tue Mar 25 13:37:30 CET 2014] epm = 318
> [Tue Mar 25 13:37:40 CET 2014] epm = 774
> Total events: 1000
> [Tue Mar 25 13:37:50 CET 2014] epm = 1259
> [Tue Mar 25 13:38:00 CET 2014] epm = 1746
> Total events: 2000
> [Tue Mar 25 13:38:10 CET 2014] epm = 2233
> [Tue Mar 25 13:38:20 CET 2014] epm = 2720
> Total events: 3000
> [Tue Mar 25 13:38:30 CET 2014] epm = 2890
> [Tue Mar 25 13:38:40 CET 2014] epm = 2922
> Total events: 4000
> [Tue Mar 25 13:38:50 CET 2014] epm = 2926
> [Tue Mar 25 13:39:00 CET 2014] epm = 2929
> Total events: 5000
> [Tue Mar 25 13:39:10 CET 2014] epm = 2933
> [Tue Mar 25 13:39:20 CET 2014] epm = 2938
> Total events: 6000
> [Tue Mar 25 13:39:30 CET 2014] epm = 2944
> [Tue Mar 25 13:39:40 CET 2014] epm = 2948
> Total events: 7000
> [Tue Mar 25 13:39:50 CET 2014] epm = 2952
> [Tue Mar 25 13:40:00 CET 2014] epm = 2956
> Total events: 8000
> [Tue Mar 25 13:40:10 CET 2014] epm = 2958
> [Tue Mar 25 13:40:20 CET 2014] epm = 2959
> Total events: 9000
> [Tue Mar 25 13:40:30 CET 2014] epm = 2959
> [Tue Mar 25 13:40:40 CET 2014] epm = 2960
> Total events: 10000
> [Tue Mar 25 13:40:50 CET 2014] epm = 2960
> [Tue Mar 25 13:41:00 CET 2014] epm = 2960
> Total events: 11000
> [Tue Mar 25 13:41:10 CET 2014] epm = 2961
> [Tue Mar 25 13:41:20 CET 2014] epm = 2963
> Total events: 12000
> [Tue Mar 25 13:41:30 CET 2014] epm = 2964
> [Tue Mar 25 13:41:40 CET 2014] epm = 2964
> Total events: 13000
> [Tue Mar 25 13:41:50 CET 2014] epm = 2966
> [Tue Mar 25 13:42:00 CET 2014] epm = 2966
> Total events: 14000
> [Tue Mar 25 13:42:10 CET 2014] epm = 2967
> [Tue Mar 25 13:42:20 CET 2014] epm = 2964
> Total events: 15000
> [Tue Mar 25 13:42:30 CET 2014] epm = 2965
> [Tue Mar 25 13:42:40 CET 2014] epm = 2966
> Total events: 16000
> [Tue Mar 25 13:42:50 CET 2014] epm = 2965
> [Tue Mar 25 13:43:00 CET 2014] epm = 2967
> Total events: 17000
> [Tue Mar 25 13:43:10 CET 2014] epm = 2966
> [Tue Mar 25 13:43:20 CET 2014] epm = 2969
> Total events: 18000
> [Tue Mar 25 13:43:30 CET 2014] epm = 2969
> [Tue Mar 25 13:43:40 CET 2014] epm = 2969
> [Tue Mar 25 13:43:50 CET 2014] epm = 2970
> Total events: 19000
> [Tue Mar 25 13:44:00 CET 2014] epm = 2969
> [Tue Mar 25 13:44:10 CET 2014] epm = 2970
> Total events: 20000
> [Tue Mar 25 13:44:20 CET 2014] epm = 2969
> [Tue Mar 25 13:44:30 CET 2014] epm = 2969
> Total events: 21000
> [Tue Mar 25 13:44:40 CET 2014] epm = 2969
> [Tue Mar 25 13:44:50 CET 2014] epm = 2969
> Total events: 22000
> [Tue Mar 25 13:45:00 CET 2014] epm = 2969
> [Tue Mar 25 13:45:10 CET 2014] epm = 2969
> Total events: 23000
> [Tue Mar 25 13:45:20 CET 2014] epm = 2969
> [Tue Mar 25 13:45:30 CET 2014] epm = 2968
> Total events: 24000
> [Tue Mar 25 13:45:40 CET 2014] epm = 2969
> [Tue Mar 25 13:45:50 CET 2014] epm = 2969
> Total events: 25000
> [Tue Mar 25 13:46:00 CET 2014] epm = 2969
> [Tue Mar 25 13:46:10 CET 2014] epm = 2969
> Total events: 26000
> [Tue Mar 25 13:46:20 CET 2014] epm = 2968
> [Tue Mar 25 13:46:30 CET 2014] epm = 2969
> Total events: 27000
> [Tue Mar 25 13:46:40 CET 2014] epm = 2968
> [Tue Mar 25 13:46:50 CET 2014] epm = 2969
> Total events: 28000
> [Tue Mar 25 13:47:00 CET 2014] epm = 2969
> [Tue Mar 25 13:47:10 CET 2014] epm = 2969
> Total events: 29000
> [Tue Mar 25 13:47:20 CET 2014] epm = 2969
>
>
>
>
> --
> View this message in context: http://drools.46999.n3.nabble.com/rules-users-Drools-Fusion-inconsistencies-at-increasing-event-throughputs-tp4028947p4028955.html
> Sent from the Drools: User forum mailing list archive at Nabble.com.
> _______________________________________________
> rules-users mailing list
> rules-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
>
> --
> Vieri Emiliani
> vieri.emiliani at gmail.com
> +39 335 1293649
> _______________________________________________
> rules-users mailing list
> rules-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/rules-users/attachments/20140328/9c07ced1/attachment-0001.html
More information about the rules-users
mailing list