if (cplan.getPathToAliases().get(taskTmpDir) == null) {
cplan.getPathToAliases().put(taskTmpDir, new ArrayList<String>());
}
cplan.getPathToAliases().get(taskTmpDir).add(streamDesc);
cplan.getPathToPartitionInfo().put(taskTmpDir, new partitionDesc(tt_desc, null));
cplan.getAliasToWork().put(streamDesc, op);
// TODO: Allocate work to remove the temporary files and make that
// dependent on the redTask
if (reducer.getClass() == JoinOperator.class)