flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: [QUESTION] In the DataExchangeMode.BATCH how does the consumer being notified to start consumer the data?
Date Tue, 31 Mar 2015 21:34:13 GMT
Hey Henry,

1) There is no extra message, but this is piggy backed with the finished
state transition (see Execution#markAsFinished). There it is essentially
the same mechanism.

2) It's part of my plan for this week to add  documentation for exactly
this flow of RPC messages related to the runtime results.

– Ufuk

On Tuesday, March 31, 2015, Henry Saputra <henry.saputra@gmail.com> wrote:

> HI Flinksters,
> Have one quick question, hopefully someone could help me get some answers:
> When is the DataExchangeMode.BATCH is actually being used, and how
> does the consumer know when to start consuming the buffer
> In the pipelined mode, the producer tell JobManager via JobManager !
> ScheduleOrUpdateConsumers to create network connection. But I could
> not find trigger for blocking/ batch mode of execution.
> - Henry

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message