Cool! Glad it solved your issue. I'm not sure if it's really documented any where or just implied someplace. I ran in to the same issue a year ago when I started mapreduce and I can't remember how I figured out to do that.
On Tue, Jan 18, 2011 at 5:00 AM, Arun Ramanujapuram <arun_rama...@yahoo.com>wrote: > Thank you, Stephen. This works. I could not locate this earlier in the > mapreduce documentation. > > Regards, > Arun > > ------------------------------ > *From:* Stephen Johnson <onepagewo...@gmail.com> > *To:* google-appengine-java@googlegroups.com > *Sent:* Sun, 16 January, 2011 1:33:31 AM > *Subject:* Re: [appengine-java] Mutation pool bug? > > Do you have this defined in your mapper class? > > @Override > > public void taskCleanup(Context context) { > > try { > > // make sure to call super classes taskCleanup so that the > DatastoreMutationPool > > // gets flushed properly otherwise puts/deletes can be lost; > > super.taskCleanup(context); > > } catch (Exception ex) { > > log.severe(ex.toString()); > > } > > } > > > On Fri, Jan 14, 2011 at 11:34 PM, armanuj <arun_rama...@yahoo.com> wrote: > >> Hi, >> >> I had earlier posted an issue such as "out of mapper quota" earlier >> (link below). I had about 260 entities being mapped (for a start), and >> not entities were getting updated. I was using the mutation pool for >> updates in the map routine. On further investigations, it appears that >> the mutation pool flushes after every 100 entities in it, and does not >> do so for the last batch of entities. Out of the 260 entities, >> everytime 60 entities would NOT be updated, but 200 would be. This >> appeared to be true even if your entity count was a multiple of 100 - >> the last 100 were not getting updated. However, this issue does not >> exist if I get rid of mutation pool, and put entities directly to the >> datastore - all entities are updated always. >> >> Is this is a bug, or is there something I am not doing correctly with >> mutation pools? The mutation pool code is fairly simple >> (mutationPool.put(entity)) - just as in Ikai's mapper blog post. >> >> Appreciate your help with this. >> >> Regards, >> Arun >> >> Earlier post: >> >> http://groups.google.com/group/google-appengine-java/browse_thread/thread/fe7fd75e2fa19a7e/a94b0efc6e50c361?hl=en&lnk=gst&q=out+of+mapper+quota#a94b0efc6e50c361 >> >> -- >> You received this message because you are subscribed to the Google Groups >> "Google App Engine for Java" group. >> To post to this group, send email to >> google-appengine-java@googlegroups.com. >> To unsubscribe from this group, send email to >> google-appengine-java+unsubscr...@googlegroups.com<google-appengine-java%2bunsubscr...@googlegroups.com> >> . >> For more options, visit this group at >> http://groups.google.com/group/google-appengine-java?hl=en. >> >> > -- > You received this message because you are subscribed to the Google Groups > "Google App Engine for Java" group. > To post to this group, send email to > google-appengine-java@googlegroups.com. > To unsubscribe from this group, send email to > google-appengine-java+unsubscr...@googlegroups.com<google-appengine-java%2bunsubscr...@googlegroups.com> > . > For more options, visit this group at > http://groups.google.com/group/google-appengine-java?hl=en. > > -- > You received this message because you are subscribed to the Google Groups > "Google App Engine for Java" group. > To post to this group, send email to > google-appengine-java@googlegroups.com. > To unsubscribe from this group, send email to > google-appengine-java+unsubscr...@googlegroups.com<google-appengine-java%2bunsubscr...@googlegroups.com> > . > For more options, visit this group at > http://groups.google.com/group/google-appengine-java?hl=en. > -- You received this message because you are subscribed to the Google Groups "Google App Engine for Java" group. To post to this group, send email to google-appengine-java@googlegroups.com. To unsubscribe from this group, send email to google-appengine-java+unsubscr...@googlegroups.com. For more options, visit this group at http://groups.google.com/group/google-appengine-java?hl=en.