State Store restoration is done on the same thread as processing. It is actually interleaved with processing, so we keep the poll time small so that if there is no data immediately available we can continue to process data from other running tasks.
On Tue, 9 Jan 2018 at 08:03 Sameer Kumar <sam.kum.w...@gmail.com> wrote: > In StoreChangelogReader.restore, we have a very short poll interval of 10 > ms. Any specfic reasons for the same. > > -Sameer. >
