flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: TaskManager & task slots
Date Tue, 27 Sep 2016 12:51:33 GMT
On Mon, Sep 26, 2016 at 9:46 PM, Ramanan, Buvana (Nokia - US)
<buvana.ramanan@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).

Mime
View raw message