[FLINK-820] Support for disconnected data flows