[ https://issues.jboss.org/browse/DROOLS-1362?page=com.atlassian.jira.plugi... ] Mario Fusco resolved DROOLS-1362. --------------------------------- Resolution: Incomplete Description I tried different scenario (see the test cases I'm pasting below) but couldn't find any relevant problem. Please try with a newer version of drools and if you think that the problem is still there feel free to reopen this ticket attaching a more complete reproducer. {code} @Test public void testManyInsertWithAccumulate() throws InterruptedException { final String drl = "package org.drools.compiler\n" + "import " + StockTick.class.getCanonicalName() + ";\n" + "global java.util.List results;\n" + "\n" + "declare StockTick \n" + " @role( event )\n" + " @expires( 1m )\n" + "end\n" + "\n" + "rule R when\n" + " accumulate( StockTick( company == \"ACME\", $price : price ) over window:time( 30s ); $avg : average($price) )\n" + "then\n" + " results.add( $avg );\n" + "end\n"; final KieBase kbase = KieBaseUtil.getKieBaseFromKieModuleFromDrl("cep-esp-test", kieBaseTestConfiguration, drl); final KieSession ksession = kbase.newKieSession(); // KieSessionTestConfiguration.STATEFUL_PSEUDO.getKieSessionConfiguration(), null); try { List<Number> results = new ArrayList<>(); ksession.setGlobal( "results", results ); long counter = 0; long start = System.currentTimeMillis(); while (System.currentTimeMillis() - start < 30_000L) { ksession.insert( new StockTick( counter, "ACME", counter++ ) ); Thread.sleep( 1L ); } long beforeFire = System.currentTimeMillis(); ksession.fireAllRules(); System.out.println("firing took " + (System.currentTimeMillis() - beforeFire) + " msecs"); System.out.println(results); } finally { ksession.dispose(); } } @Test public void testManyInsertWithAccumulate2() throws InterruptedException { final String drl = "package org.drools.compiler\n" + "import " + StockTick.class.getCanonicalName() + ";\n" + "global java.util.List results;\n" + "\n" + "declare StockTick \n" + " @role( event )\n" + " @expires( 1m )\n" + "end\n" + "\n" + "rule R when\n" + " accumulate( StockTick( company == \"ACME\", $price : price ) over window:time( 30s ); $avg : average($price) )\n" + "then\n" + " results.add( $avg );\n" + "end\n"; final KieBase kbase = KieBaseUtil.getKieBaseFromKieModuleFromDrl( "some-test", KieBaseTestConfiguration.STREAM_IDENTITY, drl ); final KieSession ksession = kbase.newKieSession(); // KieSessionTestConfiguration.STATEFUL_PSEUDO.getKieSessionConfiguration(), null); try { final List<Number> results = new ArrayList<>(); ksession.setGlobal( "results", results ); final ExecutorService executorService = Executors.newSingleThreadExecutor(); // executorService.submit((Runnable) ksession::fireUntilHalt); try { long counter = 0; final long start = System.currentTimeMillis(); while (System.currentTimeMillis() - start < 50_000L) { final long beforeInsert = System.currentTimeMillis(); ksession.insert( new StockTick( counter, "ACME", counter++ ) ); Thread.sleep( 1L ); final long insertTime = System.currentTimeMillis() - beforeInsert; if ( insertTime > 2 ) { System.out.println( "insert took " + insertTime + " msecs" ); } } } finally { // ksession.halt(); executorService.shutdownNow(); } } finally { ksession.dispose(); } } {code} -- This message was sent by Atlassian Jira (v7.12.1#712002)