You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Now, after all stages are scheduled, QueryResultFetcher will begin to work and use get_data to fetch results.
According to #3908 , the executor can not throw error through channels. It's possible that QueryResultFetcher may already start to work (All stages are created), but some other task get execution failed later, in this case the QueryResultFetcher won't know it.
One solution is to add a shutdown channel channel when running QueryResultFetcher, if one task execution fail, this shutdown channel will receive the info and return error.
Now, after all stages are scheduled,
QueryResultFetcher
will begin to work and useget_data
to fetch results.According to #3908 , the executor can not throw error through channels. It's possible that
QueryResultFetcher
may already start to work (All stages are created), but some other task get execution failed later, in this case theQueryResultFetcher
won't know it.One solution is to add a shutdown channel channel when running
QueryResultFetcher
, if one task execution fail, this shutdown channel will receive the info and return error.cc @liurenjie1024
The text was updated successfully, but these errors were encountered: