wenzhenghu commented on code in PR #60559:
URL: https://github.com/apache/doris/pull/60559#discussion_r2851042105
##########
fe/fe-core/src/main/java/org/apache/doris/qe/runtime/ThriftPlansBuilder.java:
##########
@@ -402,6 +403,13 @@ private static TPipelineFragmentParams
fragmentToThriftIfAbsent(
params.setLocalParams(Lists.newArrayList());
params.setWorkloadGroups(coordinatorContext.getWorkloadGroups());
+ if (connectContext != null &&
connectContext.getCurrentUserIdentity() != null) {
Review Comment:
mysql> CREATE TABLE tpch100.customer AS SELECT * FROM tpch.sf100.customer;
ERROR 1105 (HY000): errCode = 2, detailMessage =
(172.16.0.90)[INTERNAL_ERROR]Query 1edb28fa319249e5-813dbc3c8705d4de cancelled
by workload policy: test_cancel, id:1771998342446, query_time:1006(1000),
username:root(root)
mysql> insert into customer SELECT * FROM tpch.sf100.customer;
ERROR 1105 (HY000): errCode = 2, detailMessage =
(172.16.0.90)[INTERNAL_ERROR]Query fcde4fdf3d4f2a-8d01a8028fa4ccd2 cancelled by
workload policy: test_cancel, id:1771998342446, query_time:1297(1000),
username:root(root)
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
