This is an automated email from the ASF dual-hosted git repository.
starocean999 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 588c37bc678 [fix](nereids)fix some show command's redirect policy
(#55185)
588c37bc678 is described below
commit 588c37bc678dbe42b1b805c04ec0e478e8a97f99
Author: starocean999 <[email protected]>
AuthorDate: Tue Oct 14 15:57:40 2025 +0800
[fix](nereids)fix some show command's redirect policy (#55185)
make the command's redirect policy same as old planner:
```
ShowBackupStmt
ShowConfigStmt
ShowRestoreStmt
ShowWorkloadGroupsStmt
```
---
.../nereids/trees/plans/commands/ShowBackupCommand.java | 6 ++++++
.../nereids/trees/plans/commands/ShowConfigCommand.java | 14 ++++++++++++++
.../nereids/trees/plans/commands/ShowRestoreCommand.java | 6 ++++++
.../trees/plans/commands/ShowWorkloadGroupsCommand.java | 10 ++++++++++
4 files changed, 36 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommand.java
index e37d37d48c6..2d7c8de49b4 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowBackupCommand.java
@@ -17,6 +17,7 @@
package org.apache.doris.nereids.trees.plans.commands;
+import org.apache.doris.analysis.RedirectStatus;
import org.apache.doris.backup.AbstractJob;
import org.apache.doris.backup.BackupJob;
import org.apache.doris.catalog.Column;
@@ -187,4 +188,9 @@ public class ShowBackupCommand extends ShowCommand {
public <R, C> R accept(PlanVisitor<R, C> visitor, C context) {
return visitor.visitShowBackupCommand(this, context);
}
+
+ @Override
+ public RedirectStatus toRedirectStatus() {
+ return RedirectStatus.FORWARD_NO_SYNC;
+ }
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowConfigCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowConfigCommand.java
index a53f8febe12..1e00ab3d76b 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowConfigCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowConfigCommand.java
@@ -17,6 +17,7 @@
package org.apache.doris.nereids.trees.plans.commands;
+import org.apache.doris.analysis.RedirectStatus;
import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.ScalarType;
@@ -177,4 +178,17 @@ public class ShowConfigCommand extends Command implements
NoForward {
public <R, C> R accept(PlanVisitor<R, C> visitor, C context) {
return visitor.visitShowConfigCommand(this, context);
}
+
+ @Override
+ public RedirectStatus toRedirectStatus() {
+ // no need forward to master for backend config
+ if (nodeType == NodeType.BACKEND) {
+ return RedirectStatus.NO_FORWARD;
+ }
+ if (ConnectContext.get().getSessionVariable().getForwardToMaster()) {
+ return RedirectStatus.FORWARD_NO_SYNC;
+ } else {
+ return RedirectStatus.NO_FORWARD;
+ }
+ }
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowRestoreCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowRestoreCommand.java
index b50adb185d7..164466ac6e1 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowRestoreCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowRestoreCommand.java
@@ -17,6 +17,7 @@
package org.apache.doris.nereids.trees.plans.commands;
+import org.apache.doris.analysis.RedirectStatus;
import org.apache.doris.backup.AbstractJob;
import org.apache.doris.backup.RestoreJob;
import org.apache.doris.catalog.Column;
@@ -211,4 +212,9 @@ public class ShowRestoreCommand extends ShowCommand {
return visitor.visitShowRestoreCommand(this, context);
}
+ @Override
+ public RedirectStatus toRedirectStatus() {
+ return RedirectStatus.FORWARD_NO_SYNC;
+ }
+
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowWorkloadGroupsCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowWorkloadGroupsCommand.java
index d33a21c4da8..684d559b723 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowWorkloadGroupsCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowWorkloadGroupsCommand.java
@@ -17,6 +17,7 @@
package org.apache.doris.nereids.trees.plans.commands;
+import org.apache.doris.analysis.RedirectStatus;
import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.ScalarType;
@@ -87,4 +88,13 @@ public class ShowWorkloadGroupsCommand extends ShowCommand {
public String toString() {
return toSql();
}
+
+ @Override
+ public RedirectStatus toRedirectStatus() {
+ if (ConnectContext.get().getSessionVariable().getForwardToMaster()) {
+ return RedirectStatus.FORWARD_NO_SYNC;
+ } else {
+ return RedirectStatus.NO_FORWARD;
+ }
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
