What steps will reproduce the problem?
Process batches in parallel with WordCountStep in the pipeline (sample code
attached).
What is the expected output? What do you see instead?
Should compute metrics as if in single thread. See concurrency issues (see
output.txt attached).
What version of the product are you using? On what operating system?
Version: 0.12, Linux
Please provide any additional information below.
Original issue reported on code.google.com by jean.aur...@gmail.com on 13 Oct 2011 at 3:46
Original issue reported on code.google.com by
jean.aur...@gmail.com
on 13 Oct 2011 at 3:46Attachments: