failingMapReduce.js

var mapByOrgID = function(){
	var orgID = this.OrgID;
	if(orgID)
		emit(orgID, { ecosystem: this.ecosystem });
};

var reduceEcosystems = function(key, values){
	var ret = {
		orgID: key,
		ecosystems: []
	};

	_.each(values, function(item){
		if(item.ecosystem && !_.contains(ret.ecosystems, item.ecosystem))
			ret.ecosystems.push(item.ecosystem);
	});

	return ret;
};


staging.init(function(err, stagingDb){
	var mrOptions = {
		query: {
			OrgID: { $exists: true, $ne: null }
		},
		out: {
			reduce: reducedOrganizationsCollection
		}
	};

	stagingDb.mongoClient.collection(organizationsCollection).mapReduce(mapByOrgID, 
		reduceEcosystems, mrOptions, function(err, collection){
			console.info(util.format('Finished reducing organizations to collection %s', reducedOrganizationsCollection));
	});
});