On Mon, Sep 26, 2016 at 9:46 PM, Ramanan, Buvana (Nokia - US) <buvana.rama...@nokia-bell-labs.com> wrote: > When the operators (including source / sink) are chained, what is the method > of communication between them?
In general, when operators are chained they execute in the same "physical" task and records are passed directly to the next operator without any serialization happening. When they are not chained, records are serialized into Flink's Buffer instances and the consuming operator fetches them (either locally or remotely).
