[rules-users] Drools Fusion inconsistencies at increasing event throughputs
Vieri
vieri.emiliani at gmail.com
Tue Mar 25 12:09:51 EDT 2014
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
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/rules-users/attachments/20140325/51cf7463/attachment-0001.html
More information about the rules-users
mailing list