Commit e5fba012 authored by gerd's avatar gerd

Using default replication for reduce output


git-svn-id: https://gps.dynxs.de/private/svn/app-plasma/[email protected] 55289a75-7b90-4627-9e07-ffb4263930b2
parent bb9d76ef
......@@ -261,7 +261,8 @@ let exec_shuffle_task me mj (t:shuffle_task) =
(fun (filename,fpmin,fpmax) ->
if fpmin < pmin || fpmin > fpmax || fpmax > pmax then
failwith "Shuffle: bad output partitions";
Mapred_io.create_file ~repl:1 c filename;
let repl = if t.shuffle_reduce then 0 else 1 in
Mapred_io.create_file ~repl c filename;
let writer =
Mapred_io.write_file c filename in
Stack.push (fun () -> writer # close_out()) cleanup;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment