Changeset: 5d33f71d1e03 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=5d33f71d1e03
Modified Files:
MonetDB5/src/optimizer/opt_mapreduce.mx
Branch: default
Log Message:
remove parallelisation limitation based on GDKthreads that snuck in during
'Minor additions to mapreduce', remove NOOP code from the final reduce plan
diffs (23 lines):
diff -r 06e9b35bb178 -r 5d33f71d1e03 MonetDB5/src/optimizer/opt_mapreduce.mx
--- a/MonetDB5/src/optimizer/opt_mapreduce.mx Tue May 25 10:47:11 2010 +0200
+++ b/MonetDB5/src/optimizer/opt_mapreduce.mx Tue May 25 10:56:24 2010 +0200
@@ -125,8 +125,6 @@
mapnodes[mapcount].pass = GDKstrdup("monetdb");
mapcount++;
}
- if (GDKnr_threads < (int) BATcount(cloud))
- GDKnr_threads = (int) BATcount(cloud);
mal_unset_lock(mal_contextLock, "mapreduce");
BBPkeepref(*ret); /* give it to the called */
@@ -559,6 +557,10 @@
continue;
}
+ /* skip all NOOPs */
+ if (p->token == NOOPsymbol)
+ continue;
+
if (getModuleId(p) == algebraRef && (
getFunctionId(p) == sortTailRef ||
getFunctionId(p) == sortReverseTailRef
||
_______________________________________________
Checkin-list mailing list
[email protected]
http://mail.monetdb.org/mailman/listinfo/checkin-list
