fix #MLHR-991 DAG Stream Locality
Merge pull request #872 from nickholub/dag2

fix #MLHR-991 DAG Stream Locality