"failed to get records for spark-executor after polling for ***" error

"failed to get records for spark-executor after polling for ***" error

Some kafka consumer tasks throw "failed to get records for spark-executor after polling for ***" error some times. In detail, some tasks take very long time, and throw this error. However while the task restarts, it recovers very soon.

Some kafka consumer tasks throw "failed to get records for spark-executor after polling for ***" error some times. In detail, some tasks take very long time, and throw this error. However while the task restarts, it recovers very soon.