-
Notifications
You must be signed in to change notification settings - Fork 3.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[fix](cloud) Fix the error of Cloud forwarding SQL not finding the cluster #41819
Conversation
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
run buildall |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
PR approved by anyone and no changes requested. |
TPC-H: Total hot run time: 41476 ms
|
TPC-DS: Total hot run time: 193219 ms
|
PR approved by at least one committer and no changes requested. |
ClickBench: Total hot run time: 32.67 s
|
…uster (apache#41819) …uster ## Proposed changes 1. fix follower ddl sql forward not have cluster, throw exception ``` 2024-10-14 14:27:11,076 WARN (mysql-nio-pool-4|110) [MasterOpExecutor.buildStmtForwardParams():220] failed to get cloud compute group org.apache.doris.cloud.qe.ComputeGroupException: errCode = 2, detailMessage = default compute group smoke_test_cluster_01 check auth failed, ComputeGroupException: CURRENT_USER_NO_AUTH_TO_USE_DEFAULT_COMPUTE_GROUP, you can contact the system administrator and request that they grant you the default compute group permissions, use SQL `SHOW PROPERTY like 'default_compute_group'` and `GRANT USAGE_PRIV ON COMPUTE GROUP {compute_group_name} TO {user}` at org.apache.doris.qe.ConnectContext.getCloudCluster(ConnectContext.java:1241) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MasterOpExecutor.buildStmtForwardParams(MasterOpExecutor.java:218) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MasterOpExecutor.execute(MasterOpExecutor.java:89) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.forwardToMaster(StmtExecutor.java:1172) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:981) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:639) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.queryRetry(StmtExecutor.java:557) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:547) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ConnectProcessor.executeQuery(ConnectProcessor.java:397) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:238) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.handleQuery(MysqlConnectProcessor.java:194) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.dispatch(MysqlConnectProcessor.java:222) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.processOnce(MysqlConnectProcessor.java:281) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] at java.lang.Thread.run(Thread.java:833) ~[?:?] ``` 2. remove useless log in replay ``` 2024-10-14 10:21:08,479 WARN (replayer|14) [Replica.getBackendIdWithoutException():247] getBackendIdWithoutException: org.apache.doris.cloud.qe.ComputeGroupException: errCode = 2, detailMessage = connect context not set, ComputeGroupException: CONNECT_CONTEXT_NOT_SET, you can contact the system administrator, unless it's a daemon job in log, check your job at org.apache.doris.cloud.catalog.CloudReplica.getCurrentClusterId(CloudReplica.java:244) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.cloud.catalog.CloudReplica.getBackendId(CloudReplica.java:160) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.catalog.Replica.getBackendIdWithoutException(Replica.java:245) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.catalog.TabletInvertedIndex.addReplica(TabletInvertedIndex.java:631) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.datasource.InternalCatalog.replayAddPartition(InternalCatalog.java:1926) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.catalog.Env.replayAddPartition(Env.java:3343) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.persist.EditLog.loadJournal(EditLog.java:257) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.catalog.Env.replayJournal(Env.java:2962) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.catalog.Env$4.runOneCycle(Env.java:2724) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.common.util.Daemon.run(Daemon.java:116) ~[doris-fe.jar:1.2-SNAPSHOT] ``` 3. fix SHOW PROC '/dbs/1728872463112/1728872489388/partitions/1728872489387/1728872489389/1728872489392'; ``` 2024-10-14 19:51:02,673 WARN (mysql-nio-pool-0|119) [StmtExecutor.executeByLegacy():1097] execute Exception. stmt[17, 63ff6f3a58d84db5-9f1ab6642ce976de] java.lang.UnsupportedOperationException: null at java.util.AbstractList.add(AbstractList.java:153) ~[?:?] at java.util.AbstractList.add(AbstractList.java:111) ~[?:?] at org.apache.doris.common.proc.ReplicasProcNode.fetchResult(ReplicasProcNode.java:142) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.analysis.ShowProcStmt.getMetaData(ShowProcStmt.java:68) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ShowExecutor.handleShowProc(ShowExecutor.java:786) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ShowExecutor.execute(ShowExecutor.java:317) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.handleShow(StmtExecutor.java:2844) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:1059) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:639) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.queryRetry(StmtExecutor.java:557) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:547) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ConnectProcessor.executeQuery(ConnectProcessor.java:397) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:238) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.handleQuery(MysqlConnectProcessor.java:194) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.dispatch(MysqlConnectProcessor.java:222) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.qe.MysqlConnectProcessor.processOnce(MysqlConnectProcessor.java:281) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] at java.lang.Thread.run(Thread.java:833) ~[?:?] ``` Issue Number: close #xxx <!--Describe your changes.-->
…uster
Proposed changes
Issue Number: close #xxx