You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by "wanggx (via GitHub)" <gi...@apache.org> on 2025/10/14 09:46:17 UTC
Re: [PR] [fix](flink) Fix scanner be cancelled early on pipelineX [doris]
wanggx commented on PR #42421:
URL: https://github.com/apache/doris/pull/42421#issuecomment-3400998480
> 1. A query_id is randomly generated to replace t_query_plan_info.query_id. external query does not need to report anything to FE, so the query_id can be changed.
> Otherwise, multiple independent concurrent open tablet scanners have the same query_id. when one of the scanners ends, the other scanners will be canceled through FragmentMgr.cancel(query_id).
> 2. (query_id, fragment_id) is executed only on one BE, locks _pipeline_map.
> 3. External query (flink/spark read tablets) not need to report to FE.
according to your describe,when multiple independent concurrent open tablet scanners ,must cause an error,why has this problem,I cannot understand it .
https://doris-forum.org.cn/questions/D15j4/tong-guo-de-fang-shi-fang-wen-biao-ti-shi-bao-cuo
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org