X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=include%2Fhfta%2Frunning_gb_operator.h;h=ca2e7fc0c9bd88a8bbc8b87868d29154489620bf;hb=52bf6cf53a585197f998187399ebfd88681d4490;hp=3dbe9460c37faaf7f800a02ad7b7991355ea8b8b;hpb=393a42a5b1ba6e64bd3eabf7d0ce2f197e966355;p=com%2Fgs-lite.git

diff --git a/include/hfta/running_gb_operator.h b/include/hfta/running_gb_operator.h
index 3dbe946..ca2e7fc 100644
--- a/include/hfta/running_gb_operator.h
+++ b/include/hfta/running_gb_operator.h
@@ -48,7 +48,7 @@ public:
 		ret = func.create_group(tup, (gs_sp_t)&grp);
 		nflushes = func.flush_needed();
 		if(func.disordered()){
-			fprintf(stderr,"Out of order record in %s\n",op_name);
+			// fprintf(stderr,"Out of order record in %s\n",op_name);
 			return 0;
 		}
 
@@ -89,7 +89,7 @@ public:
 		typename hash_table<group, aggregate, hasher_func, equal_func>::iterator iter;
 
 //	Limit the number of successive flushes - avoid explosive behavior
-		const gs_int32_t max_flushes = 10;
+		const gs_int32_t max_flushes = 25;
 		if(nflushes>max_flushes){
 			fprintf(stderr,"Warning in operator %s, temporal advance of %d windows needed, max number of windows that can be reported at once is %d\n",op_name, nflushes, max_flushes);
 			nflushes = max_flushes;