Hi

In spark streaming 1.3 with kafka- when does driver bring latest offsets of
this run - at start of each batch or at time when  batch gets queued ?

Say few of my batches take longer time to complete than their batch
interval. So some of batches will go in queue. Will driver waits for
 queued batches to get started or just brings the latest offsets before
they even actually started. And when they start running they will work on
old offsets brought at time when they were queued.

Reply via email to