Would be better if you share some code block to understand it better. Else would be difficult to provide answer.
~Shyam On Wed, Mar 6, 2019 at 8:38 AM JF Chen <darou...@gmail.com> wrote: > When my kafka executor reads data from kafka, sometimes it throws the > error "java.lang.AssertionError: assertion failed: Failed to get records > for **** after polling for 180000" , which after 3 minutes of executing. > The data waiting for read is not so huge, which is about 1GB. And other > partitions read by other tasks are very fast, the error always occurs on > some specific executor.. > > Regard, > Junfeng Chen >
