fix #361 Logical DAG - Stream Locality