Improve error messages for data sinks inside iterations.
[FLINK-1018] Add tests to verify correct placement of pipeline breakers with broadcast variables
[FLINK-1018] Fix cross pipelining/daming info to resolve cross-related streaming deadlocks.