Github user HeartSaVioR commented on the issue:
https://github.com/apache/spark/pull/21445
@LiangchangZ
Looks like the patch is needed only with #21353 #21332 #21293 as of now,
right? If then please state the condition in JIRA issue description as well as
PR's description so that we don't get confused.
There's a case that reader and writer are composed together in a task
(current state of continuous processing), and then after this patch it will be
two places which increase epoch for the same thread. Please note that I'm
commenting on top of current implementation, not considering #21353 #21332
#21293.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
