diff --git a/compiler/optimizer/parallelize.go b/compiler/optimizer/parallelize.go index 3dd0355455..0434a4d2ee 100644 --- a/compiler/optimizer/parallelize.go +++ b/compiler/optimizer/parallelize.go @@ -246,7 +246,10 @@ func (o *Optimizer) concurrentPath(ops []dag.Op, sortKey order.SortKey) (int, or } return k, newKey, false, true, nil case *dag.Load: - return k, order.Nil, true, true, nil + // XXX At somepoint Load should have an optimization where if the + // upstream sort is the same as the Load destination sort we + // request a merge and set the Load operator to do a sorted write. + return k, order.Nil, false, false, nil case *dag.Fork, *dag.Scatter, *dag.Head, *dag.Tail, *dag.Uniq, *dag.Fuse, *dag.Join: return k, sortKey, true, true, nil default: