Thank you Ufuk! Once the execution graph is arrived at, is there a way to 'view' the graph to understand operator chaining & slot placement specific to my scenario?
-----Original Message----- From: Ufuk Celebi [mailto:u...@apache.org] Sent: Tuesday, September 27, 2016 8:52 AM To: user@flink.apache.org Subject: Re: TaskManager & task slots 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).
