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.sapu...@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 >
