This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit c90313cc05797700c2ab24ab97e00a6517401e39
Author: morrySnow <101034200+morrys...@users.noreply.github.com>
AuthorDate: Tue Sep 3 18:27:27 2024 +0800
[opt](Nereids) add show statement syntax (#40288)
---
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 136 ++++++++++++++++++++-
fe/fe-core/src/main/cup/sql_parser.cup | 4 +-
.../org/apache/doris/analysis/AlterRoleStmt.java | 2 +-
.../org/apache/doris/analysis/AnalyzeStmt.java | 2 +-
.../org/apache/doris/analysis/CreateRoleStmt.java | 2 +-
.../java/org/apache/doris/analysis/DdlStmt.java | 2 +-
.../apache/doris/analysis/DiagnoseTabletStmt.java | 2 +-
.../org/apache/doris/analysis/DropUserStmt.java | 2 +-
.../java/org/apache/doris/analysis/ExportStmt.java | 2 +-
.../doris/analysis/InsertOverwriteTableStmt.java | 2 +-
.../java/org/apache/doris/analysis/SelectStmt.java | 2 +-
.../doris/analysis/SetDefaultStorageVaultStmt.java | 2 +-
.../apache/doris/analysis/SetOperationStmt.java | 2 +-
.../apache/doris/analysis/SetUserPropertyStmt.java | 2 +-
.../org/apache/doris/analysis/ShowAlterStmt.java | 2 +-
.../org/apache/doris/analysis/ShowAnalyzeStmt.java | 2 +-
.../doris/analysis/ShowAnalyzeTaskStatus.java | 2 +-
.../org/apache/doris/analysis/ShowAuthorStmt.java | 2 +-
.../doris/analysis/ShowAutoAnalyzeJobsStmt.java | 2 +-
.../apache/doris/analysis/ShowBackendsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowBackupStmt.java | 2 +-
.../org/apache/doris/analysis/ShowBrokerStmt.java | 2 +-
.../apache/doris/analysis/ShowBuildIndexStmt.java | 2 +-
.../doris/analysis/ShowCacheHotSpotStmt.java | 2 +-
.../doris/analysis/ShowCatalogRecycleBinStmt.java | 2 +-
.../org/apache/doris/analysis/ShowCatalogStmt.java | 2 +-
.../org/apache/doris/analysis/ShowCharsetStmt.java | 2 +-
.../apache/doris/analysis/ShowCloudWarmUpStmt.java | 2 +-
.../org/apache/doris/analysis/ShowClusterStmt.java | 2 +-
.../apache/doris/analysis/ShowCollationStmt.java | 2 +-
.../apache/doris/analysis/ShowColumnHistStmt.java | 2 +-
.../apache/doris/analysis/ShowColumnStatsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowColumnStmt.java | 2 +-
.../apache/doris/analysis/ShowConvertLSCStmt.java | 2 +-
.../org/apache/doris/analysis/ShowCopyStmt.java | 2 +-
.../doris/analysis/ShowCreateCatalogStmt.java | 2 +-
.../apache/doris/analysis/ShowCreateDbStmt.java | 2 +-
.../doris/analysis/ShowCreateFunctionStmt.java | 2 +-
.../apache/doris/analysis/ShowCreateMTMVStmt.java | 2 +-
.../analysis/ShowCreateMaterializedViewStmt.java | 2 +-
.../doris/analysis/ShowCreateRepositoryStmt.java | 2 +-
.../apache/doris/analysis/ShowCreateTableStmt.java | 2 +-
.../apache/doris/analysis/ShowDataSkewStmt.java | 2 +-
.../org/apache/doris/analysis/ShowDataStmt.java | 2 +-
.../apache/doris/analysis/ShowDataTypesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowDbIdStmt.java | 2 +-
.../java/org/apache/doris/analysis/ShowDbStmt.java | 2 +-
.../org/apache/doris/analysis/ShowDeleteStmt.java | 2 +-
.../doris/analysis/ShowDynamicPartitionStmt.java | 2 +-
.../apache/doris/analysis/ShowEncryptKeysStmt.java | 2 +-
.../org/apache/doris/analysis/ShowEnginesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowEventsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowExportStmt.java | 2 +-
.../apache/doris/analysis/ShowFrontendsStmt.java | 2 +-
.../apache/doris/analysis/ShowFunctionsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowGrantsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowIndexStmt.java | 2 +-
.../apache/doris/analysis/ShowLastInsertStmt.java | 2 +-
.../apache/doris/analysis/ShowLoadProfileStmt.java | 2 +-
.../org/apache/doris/analysis/ShowLoadStmt.java | 2 +-
.../doris/analysis/ShowLoadWarningsStmt.java | 2 +-
.../apache/doris/analysis/ShowOpenTableStmt.java | 2 +-
.../apache/doris/analysis/ShowPartitionIdStmt.java | 2 +-
.../apache/doris/analysis/ShowPartitionsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowPluginsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowPolicyStmt.java | 2 +-
.../apache/doris/analysis/ShowPrivilegesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowProcStmt.java | 2 +-
.../apache/doris/analysis/ShowProcedureStmt.java | 2 +-
.../apache/doris/analysis/ShowProcesslistStmt.java | 2 +-
.../doris/analysis/ShowQueryProfileStmt.java | 2 +-
.../apache/doris/analysis/ShowQueryStatsStmt.java | 2 +-
.../analysis/ShowReplicaDistributionStmt.java | 2 +-
.../doris/analysis/ShowReplicaStatusStmt.java | 2 +-
.../doris/analysis/ShowRepositoriesStmt.java | 2 +-
.../apache/doris/analysis/ShowResourcesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowRestoreStmt.java | 2 +-
.../org/apache/doris/analysis/ShowRolesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowRollupStmt.java | 2 +-
.../apache/doris/analysis/ShowSmallFilesStmt.java | 2 +-
.../apache/doris/analysis/ShowSnapshotStmt.java | 2 +-
.../doris/analysis/ShowSqlBlockRuleStmt.java | 2 +-
.../org/apache/doris/analysis/ShowStageStmt.java | 2 +-
.../org/apache/doris/analysis/ShowStatusStmt.java | 2 +-
.../java/org/apache/doris/analysis/ShowStmt.java | 2 +-
.../doris/analysis/ShowStoragePolicyUsingStmt.java | 2 +-
.../doris/analysis/ShowStorageVaultStmt.java | 2 +-
.../apache/doris/analysis/ShowStreamLoadStmt.java | 2 +-
.../org/apache/doris/analysis/ShowSyncJobStmt.java | 2 +-
.../doris/analysis/ShowTableCreationStmt.java | 2 +-
.../org/apache/doris/analysis/ShowTableIdStmt.java | 2 +-
.../apache/doris/analysis/ShowTableStatsStmt.java | 2 +-
.../apache/doris/analysis/ShowTableStatusStmt.java | 2 +-
.../org/apache/doris/analysis/ShowTableStmt.java | 2 +-
.../org/apache/doris/analysis/ShowTabletStmt.java | 2 +-
.../analysis/ShowTabletStorageFormatStmt.java | 2 +-
.../doris/analysis/ShowTabletsBelongStmt.java | 2 +-
.../apache/doris/analysis/ShowTransactionStmt.java | 2 +-
.../apache/doris/analysis/ShowTrashDiskStmt.java | 2 +-
.../org/apache/doris/analysis/ShowTrashStmt.java | 2 +-
.../apache/doris/analysis/ShowTriggersStmt.java | 2 +-
.../apache/doris/analysis/ShowTypeCastStmt.java | 2 +-
.../doris/analysis/ShowUserPropertyStmt.java | 2 +-
.../apache/doris/analysis/ShowVariablesStmt.java | 2 +-
.../org/apache/doris/analysis/ShowViewStmt.java | 2 +-
.../org/apache/doris/analysis/ShowWarningStmt.java | 2 +-
.../apache/doris/analysis/ShowWhiteListStmt.java | 2 +-
.../doris/analysis/ShowWorkloadGroupsStmt.java | 2 +-
.../org/apache/doris/analysis/TransactionStmt.java | 2 +-
.../doris/cloud/analysis/UseCloudClusterStmt.java | 3 +-
111 files changed, 244 insertions(+), 114 deletions(-)
diff --git a/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisLexer.g4
b/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisLexer.g4
index f21c8b94614..61ca36bb690 100644
--- a/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisLexer.g4
+++ b/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisLexer.g4
@@ -583,6 +583,7 @@ VAULT: 'VAULT';
VERBOSE: 'VERBOSE';
VERSION: 'VERSION';
VIEW: 'VIEW';
+VIEWS: 'VIEWS';
WARM: 'WARM';
WARNINGS: 'WARNINGS';
WEEK: 'WEEK';
diff --git a/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4
b/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4
index 013c508b52b..22a5ed91d85 100644
--- a/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4
+++ b/fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4
@@ -38,7 +38,7 @@ statement
| CALL name=multipartIdentifier LEFT_PAREN (expression (COMMA
expression)*)? RIGHT_PAREN #callProcedure
| (ALTER | CREATE (OR REPLACE)? | REPLACE) (PROCEDURE | PROC)
name=multipartIdentifier LEFT_PAREN .*? RIGHT_PAREN .*? #createProcedure
| DROP (PROCEDURE | PROC) (IF EXISTS)? name=multipartIdentifier
#dropProcedure
- | SHOW PROCEDURE STATUS (LIKE pattern=valueExpression | whereClause)?
#showProcedureStatus
+ | SHOW (PROCEDURE | FUNCTION) STATUS (LIKE pattern=valueExpression |
whereClause)? #showProcedureStatus
| SHOW CREATE PROCEDURE name=multipartIdentifier #showCreateProcedure
// FIXME: like should be wildWhere? FRONTEND should not contain FROM
backendid
| ADMIN? SHOW type=(FRONTEND | BACKEND) CONFIG (LIKE
pattern=valueExpression)? (FROM backendId=INTEGER_VALUE)? #showConfig
@@ -49,7 +49,7 @@ statementBase
| supportedDmlStatement #supportedDmlStatementAlias
| supportedCreateStatement #supportedCreateStatementAlias
| supportedAlterStatement #supportedAlterStatementAlias
- | materailizedViewStatement #materailizedViewStatementAlias
+ | materializedViewStatement #materializedViewStatementAlias
| constraintStatement #constraintStatementAlias
| supportedDropStatement #supportedDropStatementAlias
| unsupportedStatement #unsupported
@@ -75,10 +75,11 @@ unsupportedStatement
| unsupportedCleanStatement
| unsupportedRefreshStatement
| unsupportedLoadStatement
+ | unsupportedShowStatement
| unsupportedOtherStatement
;
-materailizedViewStatement
+materializedViewStatement
: CREATE MATERIALIZED VIEW (IF NOT EXISTS)? mvName=multipartIdentifier
(LEFT_PAREN cols=simpleColumnDefs RIGHT_PAREN)? buildMode?
(REFRESH refreshMethod? refreshTrigger?)?
@@ -202,6 +203,121 @@ lockTable
(READ (LOCAL)? | (LOW_PRIORITY)? WRITE)
;
+unsupportedShowStatement
+ : SHOW SQL_BLOCK_RULE (FOR ruleName=identifier)?
#showSqlBlockRule
+ | SHOW ROW POLICY (FOR (userIdentify | (ROLE role=identifier)))?
#showRowPolicy
+ | SHOW STORAGE POLICY (USING (FOR policy=identifierOrText)?)?
#showStoragePolicy
+ | SHOW STAGES
#showStages
+ | SHOW STORAGE VAULT
#showStorageVault
+ | SHOW CREATE REPOSITORY FOR identifier
#showCreateRepository
+ | SHOW WHITELIST
#showWhitelist
+ | SHOW (GLOBAL | SESSION | LOCAL)? VARIABLES wildWhere?
#showVariables
+ | SHOW OPEN TABLES ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showOpenTables
+ | SHOW TABLE STATUS ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showTableStatus
+ | SHOW FULL? TABLES ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showTables
+ | SHOW FULL? VIEWS ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showViews
+ | SHOW TABLE tableId=INTEGER_VALUE
#showTableId
+ | SHOW FULL? PROCESSLIST
#showProcessList
+ | SHOW (GLOBAL | SESSION | LOCAL)? STATUS wildWhere?
#showStatus
+ | SHOW FULL? TRIGGERS ((FROM | IN) database=multipartIdentifier)?
wildWhere? #showTriggers
+ | SHOW EVENTS ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showEvents
+ | SHOW PLUGINS
#showPlugins
+ | SHOW STORAGE? ENGINES
#showStorageEngines
+ | SHOW AUTHORS
#showAuthors
+ | SHOW BRIEF? CREATE TABLE name=multipartIdentifier
#showCreateTable
+ | SHOW CREATE VIEW name=multipartIdentifier
#showCreateView
+ | SHOW CREATE MATERIALIZED VIEW name=multipartIdentifier
#showMaterializedView
+ | SHOW CREATE (DATABASE | SCHEMA) name=multipartIdentifier
#showCreateDatabase
+ | SHOW CREATE CATALOG name=identifier
#showCreateCatalog
+ | SHOW CREATE (GLOBAL | SESSION | LOCAL)? FUNCTION functionIdentifier
+ LEFT_PAREN functionArguments? RIGHT_PAREN
+ ((FROM | IN) database=multipartIdentifier)?
#showCreateFunction
+ | SHOW (DATABASES | SCHEMAS) (FROM catalog=identifier)? wildWhere?
#showDatabases
+ | SHOW DATABASE databaseId=INTEGER_VALUE
#showDatabaseId
+ | SHOW DATA TYPES
#showDataTypes
+ | SHOW CATALOGS wildWhere?
#showCatalogs
+ | SHOW CATALOG name=identifier
#showCatalog
+ | SHOW DYNAMIC PARTITION TABLES ((FROM | IN)
database=multipartIdentifier)? #showDynamicPartition
+ | SHOW FULL? (COLUMNS | FIELDS) (FROM | IN) tableName=multipartIdentifier
+ ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showColumns
+ | SHOW COLLATION wildWhere?
#showCollation
+ | SHOW ((CHAR SET) | CHARSET) wildWhere?
#showCharset
+ | SHOW PROC path=STRING_LITERAL
#showProc
+ | SHOW COUNT LEFT_PAREN ASTERISK RIGHT_PAREN (WARNINGS | ERRORS)
#showWaringErrorCount
+ | SHOW (WARNINGS | ERRORS) limitClause?
#showWaringErrors
+ | SHOW LOAD WARNINGS ((((FROM | IN) database=multipartIdentifier)?
+ wildWhere? limitClause?) | (ON url=STRING_LITERAL))
#showLoadWarings
+ | SHOW STREAM? LOAD ((FROM | IN) database=multipartIdentifier)? wildWhere?
+ sortClause? limitClause?
#showLoad
+ | SHOW EXPORT ((FROM | IN) database=multipartIdentifier)? wildWhere?
+ sortClause? limitClause?
#showExport
+ | SHOW DELETE ((FROM | IN) database=multipartIdentifier)?
#showDelete
+ | SHOW ALTER TABLE (ROLLUP | (MATERIALIZED VIEW) | COLUMN)
+ ((FROM | IN) database=multipartIdentifier)? wildWhere?
+ sortClause? limitClause?
#showAlterTable
+ | SHOW DATA SKEW FROM baseTableRef
#showDataSkew
+ | SHOW DATA (FROM tableName=multipartIdentifier)? sortClause?
propertyClause? #showData
+ | SHOW TEMPORARY? PARTITIONS FROM tableName=multipartIdentifier
+ wildWhere? sortClause? limitClause?
#showPartitions
+ | SHOW PARTITION partitionId=INTEGER_VALUE
#showPartitionId
+ | SHOW TABLET tabletId=INTEGER_VALUE
#showTabletId
+ | SHOW TABLETS BELONG
+ tabletIds+=INTEGER_VALUE (COMMA tabletIds+=INTEGER_VALUE)*
#showTabletBelong
+ | SHOW TABLETS FROM tableName=multipartIdentifier partitionSpec?
+ wildWhere? sortClause? limitClause?
#showTabletsFromTable
+ | SHOW PROPERTY (FOR user=identifierOrText)? wildWhere?
#showUserProperties
+ | SHOW ALL PROPERTIES wildWhere?
#showAllProperties
+ | SHOW BACKUP ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showBackup
+ | SHOW BRIEF? RESTORE ((FROM | IN) database=multipartIdentifier)?
wildWhere? #showRestore
+ | SHOW BROKER
#showBroker
+ | SHOW RESOURCES wildWhere? sortClause? limitClause?
#showResources
+ | SHOW WORKLOAD GROUPS wildWhere?
#showWorkloadGroups
+ | SHOW BACKENDS
#showBackends
+ | SHOW TRASH (ON backend=STRING_LITERAL)?
#showTrash
+ | SHOW FRONTENDS name=identifier?
#showFrontends
+ | SHOW REPOSITORIES
#showRepositories
+ | SHOW SNAPSHOT ON repo=identifier wildWhere?
#showSnapshot
+ | SHOW ALL? GRANTS
#showGrants
+ | SHOW GRANTS FOR userIdentify
#showGrantsForUser
+ | SHOW ROLES
#showRoles
+ | SHOW PRIVILEGES
#showPrivileges
+ | SHOW FULL? BUILTIN? FUNCTIONS
+ ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showFunctions
+ | SHOW GLOBAL FULL? FUNCTIONS wildWhere?
#showGlobalFunctions
+ | SHOW TYPECAST ((FROM | IN) database=multipartIdentifier)?
#showTypeCast
+ | SHOW FILE ((FROM | IN) database=multipartIdentifier)?
#showSmallFiles
+ | SHOW (KEY | KEYS | INDEX | INDEXES)
+ (FROM |IN) tableName=multipartIdentifier
+ ((FROM | IN) database=multipartIdentifier)?
#showIndex
+ | SHOW VIEW
+ (FROM |IN) tableName=multipartIdentifier
+ ((FROM | IN) database=multipartIdentifier)?
#showView
+ | SHOW TRANSACTION ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showTransaction
+ | SHOW QUERY PROFILE queryIdPath=STRING_LITERAL
#showQueryProfile
+ | SHOW LOAD PROFILE loadIdPath=STRING_LITERAL
#showLoadProfile
+ | SHOW CACHE HOTSPOT tablePath=STRING_LITERAL
#showCacheHotSpot
+ | SHOW ENCRYPTKEYS ((FROM | IN) database=multipartIdentifier)? wildWhere?
#showEncryptKeys
+ | SHOW SYNC JOB ((FROM | IN) database=multipartIdentifier)?
#showSyncJob
+ | SHOW TABLE CREATION ((FROM | IN) database=multipartIdentifier)?
wildWhere? #showTableCreation
+ | SHOW LAST INSERT
#showLastInsert
+ | SHOW CREATE MATERIALIZED VIEW mvName=identifier
+ ON tableName=multipartIdentifier
#showCreateMaterializedView
+ | SHOW CATALOG RECYCLE BIN wildWhere?
#showCatalogRecycleBin
+ | SHOW QUERY STATS ((FOR database=identifier)
+ | (FROM tableName=multipartIdentifier (ALL VERBOSE?)?))?
#showQueryStats
+ | SHOW BUILD INDEX ((FROM | IN) database=multipartIdentifier)?
+ wildWhere? sortClause? limitClause?
#showBuildIndex
+ | SHOW CLUSTERS
#showClusters
+ | SHOW CONVERT_LSC ((FROM | IN) database=multipartIdentifier)?
#showConvertLsc
+ | SHOW REPLICA STATUS FROM baseTableRef wildWhere?
#showReplicaStatus
+ | SHOW REPLICA DISTRIBUTION FROM baseTableRef
#showREplicaDistribution
+ | SHOW TABLET STORAGE FORMAT VERBOSE?
#showTabletStorageFormat
+ | SHOW TABLET DIAGNOSIS tabletId=INTEGER_VALUE
#showDiagnoseTablet
+ | SHOW COPY ((FROM | IN) database=multipartIdentifier)?
+ whereClause? sortClause? limitClause?
#showCopy
+ | SHOW WARM UP JOB wildWhere?
#showWarmUpJob
+ ;
+
unsupportedLoadStatement
: LOAD mysqlDataDesc
(PROPERTIES LEFT_PAREN properties=propertyItemList RIGHT_PAREN)?
@@ -432,6 +548,7 @@ unsupportedAlterStatement
properties=propertyClause
#alterStoragePlicy
| ALTER USER (IF EXISTS)? grantUserIdentify
passwordOption (COMMENT STRING_LITERAL)?
#alterUser
+ | ALTER ROLE role=identifier commentSpec
#alterRole
| ALTER REPOSITORY name=identifier properties=propertyClause?
#alterRepository
;
@@ -562,6 +679,18 @@ unsupportedStatsStatement
| DROP EXPIRED STATS
#dropExpiredStats
| DROP ANALYZE JOB INTEGER_VALUE
#dropAanalyzeJob
| KILL ANALYZE jobId=INTEGER_VALUE
#killAnalyzeJob
+ | SHOW TABLE STATS tableName=multipartIdentifier
+ partitionSpec? columnList=identifierList?
#showTableStats
+ | SHOW TABLE STATS tableId=INTEGER_VALUE
#showTableStats
+ | SHOW INDEX STATS tableName=multipartIdentifier indexId=identifier
#showIndexStats
+ | SHOW COLUMN CACHED? STATS tableName=multipartIdentifier
+ columnList=identifierList? partitionSpec?
#showColumnStats
+ | SHOW COLUMN HISTOGRAM tableName=multipartIdentifier
+ columnList=identifierList
#showColumnHistogramStats
+ | SHOW AUTO? ANALYZE tableName=multipartIdentifier? wildWhere?
#showAnalyze
+ | SHOW ANALYZE jobId=INTEGER_VALUE wildWhere?
#showAnalyzeFromJobId
+ | SHOW AUTO JOBS tableName=multipartIdentifier? wildWhere?
#showAutoAnalyzeJobs
+ | SHOW ANALYZE TASK STATUS jobId=INTEGER_VALUE
#showAnalyzeTask
;
analyzeProperties
@@ -1945,6 +2074,7 @@ nonReserved
| VERBOSE
| VERSION
| VIEW
+ | VIEWS
| WARM
| WARNINGS
| WEEK
diff --git a/fe/fe-core/src/main/cup/sql_parser.cup
b/fe/fe-core/src/main/cup/sql_parser.cup
index 37907e44915..31c90e2e858 100644
--- a/fe/fe-core/src/main/cup/sql_parser.cup
+++ b/fe/fe-core/src/main/cup/sql_parser.cup
@@ -718,7 +718,7 @@ nonterminal StatementBase stmt, show_stmt, show_param,
help_stmt, load_stmt,
use_stmt, use_cloud_cluster_stmt, kill_stmt, drop_stmt, recover_stmt,
grant_stmt, revoke_stmt, create_stmt, set_stmt, sync_stmt, cancel_stmt,
cancel_param, delete_stmt,
switch_stmt, transaction_stmt, unsupported_stmt, export_stmt, admin_stmt,
truncate_stmt,
import_columns_stmt, import_delete_on_stmt, import_sequence_stmt,
import_where_stmt, install_plugin_stmt, uninstall_plugin_stmt,
- import_preceding_filter_stmt, unlock_tables_stmt, lock_tables_stmt,
refresh_stmt, clean_stmt, analyze_stmt, show_mtmv_stmt, kill_analysis_job_stmt,
insert_overwrite_stmt, copy_stmt,
+ import_preceding_filter_stmt, unlock_tables_stmt, lock_tables_stmt,
refresh_stmt, clean_stmt, analyze_stmt, kill_analysis_job_stmt,
insert_overwrite_stmt, copy_stmt,
warm_up_stmt;
nonterminal FromClause opt_using_clause;
@@ -1272,8 +1272,6 @@ stmt ::=
{: RESULT = stmt; :}
| analyze_stmt:stmt
{: RESULT = stmt; :}
- | show_mtmv_stmt : stmt
- {: RESULT = stmt; :}
| warm_up_stmt:stmt
{: RESULT = stmt; :}
| /* empty: query only has comments */
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterRoleStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterRoleStmt.java
index ec428cb82f4..f993b672220 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterRoleStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterRoleStmt.java
@@ -26,7 +26,7 @@ import org.apache.doris.qe.ConnectContext;
import com.google.common.base.Strings;
-public class AlterRoleStmt extends DdlStmt {
+public class AlterRoleStmt extends DdlStmt implements NotFallbackInParser {
private String role;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyzeStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyzeStmt.java
index 9b5145a7d0e..495539842b4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyzeStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyzeStmt.java
@@ -30,7 +30,7 @@ import org.apache.logging.log4j.core.util.CronExpression;
import java.util.Map;
-public class AnalyzeStmt extends StatementBase {
+public class AnalyzeStmt extends StatementBase implements NotFallbackInParser {
private static final Logger LOG = LogManager.getLogger(AnalyzeStmt.class);
protected AnalyzeProperties analyzeProperties;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRoleStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRoleStmt.java
index 1f64ceddb85..336bcc50406 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRoleStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRoleStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ConnectContext;
import com.google.common.base.Strings;
import org.apache.commons.lang3.StringUtils;
-public class CreateRoleStmt extends DdlStmt {
+public class CreateRoleStmt extends DdlStmt implements NotFallbackInParser {
private boolean ifNotExists;
private String role;
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java
index 596341bb374..38533bd49d4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java
@@ -17,7 +17,7 @@
package org.apache.doris.analysis;
-public abstract class DdlStmt extends StatementBase {
+public abstract class DdlStmt extends StatementBase implements
NotFallbackInParser {
@Override
public RedirectStatus getRedirectStatus() {
return RedirectStatus.FORWARD_WITH_SYNC;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/DiagnoseTabletStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/DiagnoseTabletStmt.java
index b86cb30199e..4b5e5c6979c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/DiagnoseTabletStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/DiagnoseTabletStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
// SHOW TABLET DIAGNOSIS tablet_id
-public class DiagnoseTabletStmt extends ShowStmt {
+public class DiagnoseTabletStmt extends ShowStmt implements
NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("Item").add("Info").add("Suggestion")
.build();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/DropUserStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/DropUserStmt.java
index e9b3e6fe794..f9bb218744f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/DropUserStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/DropUserStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ConnectContext;
// drop user cmy@['domain'];
// drop user cmy <==> drop user cmy@'%'
// drop user cmy@'192.168.1.%'
-public class DropUserStmt extends DdlStmt {
+public class DropUserStmt extends DdlStmt implements NotFallbackInParser {
private boolean ifExists;
private UserIdentity userIdent;
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java
index 232a61f1edc..a9ce85b2d3e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java
@@ -60,7 +60,7 @@ import java.util.stream.Collectors;
// [PROPERTIES("key"="value")]
// WITH BROKER 'broker_name' [( $broker_attrs)]
@Getter
-public class ExportStmt extends StatementBase {
+public class ExportStmt extends StatementBase implements NotFallbackInParser {
public static final String PARALLELISM = "parallelism";
public static final String LABEL = "label";
public static final String DATA_CONSISTENCY = "data_consistency";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/InsertOverwriteTableStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/InsertOverwriteTableStmt.java
index bef4a38bc3e..a0fca62e284 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/InsertOverwriteTableStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/InsertOverwriteTableStmt.java
@@ -34,7 +34,7 @@ import lombok.Getter;
import java.util.ArrayList;
import java.util.List;
-public class InsertOverwriteTableStmt extends DdlStmt {
+public class InsertOverwriteTableStmt extends DdlStmt implements
NotFallbackInParser {
private final InsertTarget target;
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
index b7b778ae901..d9f8e00c292 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
@@ -80,7 +80,7 @@ import java.util.stream.Collectors;
* clauses.
*/
@Deprecated
-public class SelectStmt extends QueryStmt {
+public class SelectStmt extends QueryStmt implements NotFallbackInParser {
private static final Logger LOG = LogManager.getLogger(SelectStmt.class);
public static final String DEFAULT_VALUE = "__DEFAULT_VALUE__";
private UUID id = UUID.randomUUID();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetDefaultStorageVaultStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetDefaultStorageVaultStmt.java
index 26687942d02..3c3fc6f1863 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetDefaultStorageVaultStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetDefaultStorageVaultStmt.java
@@ -29,7 +29,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
// SET vault_name DEFAULT STORAGE VAULT
-public class SetDefaultStorageVaultStmt extends DdlStmt {
+public class SetDefaultStorageVaultStmt extends DdlStmt implements
NotFallbackInParser {
public final String vaultName;
public SetDefaultStorageVaultStmt(String vaultName) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetOperationStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetOperationStmt.java
index 3c4f8a76fd5..2746da4d8fd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetOperationStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetOperationStmt.java
@@ -53,7 +53,7 @@ import java.util.stream.Collectors;
* and we need to mark the slots of resolved exprs as materialized.
*/
@Deprecated
-public class SetOperationStmt extends QueryStmt {
+public class SetOperationStmt extends QueryStmt implements NotFallbackInParser
{
private static final Logger LOG =
LogManager.getLogger(SetOperationStmt.class);
public enum Operation {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserPropertyStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserPropertyStmt.java
index 7342fe7a79c..04247fb227f 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserPropertyStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SetUserPropertyStmt.java
@@ -27,7 +27,7 @@ import com.google.common.collect.Lists;
import java.util.List;
-public class SetUserPropertyStmt extends DdlStmt {
+public class SetUserPropertyStmt extends DdlStmt implements
NotFallbackInParser {
private String user;
private final List<SetVar> propertyList;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAlterStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAlterStmt.java
index 466d958ab19..8040271005a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAlterStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAlterStmt.java
@@ -48,7 +48,7 @@ import java.util.List;
* SHOW ALTER TABLE [COLUMN | ROLLUP] [FROM dbName] [WHERE
TableName="xxx"]
* [ORDER BY CreateTime DESC] [LIMIT [offset,]rows]
*/
-public class ShowAlterStmt extends ShowStmt {
+public class ShowAlterStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowAlterStmt.class);
public static enum AlterType {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeStmt.java
index f015cdb0555..56e16bba76a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeStmt.java
@@ -45,7 +45,7 @@ import com.google.common.collect.ImmutableList;
* [ORDER BY ...]
* [LIMIT limit];
*/
-public class ShowAnalyzeStmt extends ShowStmt {
+public class ShowAnalyzeStmt extends ShowStmt implements NotFallbackInParser {
private static final String STATE_NAME = "state";
private static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("job_id")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeTaskStatus.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeTaskStatus.java
index 364e3d0a4f3..ff52cf0ccba 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeTaskStatus.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAnalyzeTaskStatus.java
@@ -26,7 +26,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
/**
* SHOW ANALYZE TASK STATUS [JOB_ID]
*/
-public class ShowAnalyzeTaskStatus extends ShowStmt {
+public class ShowAnalyzeTaskStatus extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData ROW_META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAuthorStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAuthorStmt.java
index 477efd694d2..f82f6022d41 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAuthorStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAuthorStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// Used to test show executor.
-public class ShowAuthorStmt extends ShowStmt {
+public class ShowAuthorStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Name",
ScalarType.createVarchar(30)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAutoAnalyzeJobsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAutoAnalyzeJobsStmt.java
index 560387fa5bc..9b07796df78 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAutoAnalyzeJobsStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAutoAnalyzeJobsStmt.java
@@ -43,7 +43,7 @@ import com.google.common.collect.ImmutableList;
* [PRIORITY = ["HIGH"|"MID"|"LOW"]]
* ]
*/
-public class ShowAutoAnalyzeJobsStmt extends ShowStmt {
+public class ShowAutoAnalyzeJobsStmt extends ShowStmt implements
NotFallbackInParser {
private static final String PRIORITY = "priority";
private static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("catalog_name")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackendsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackendsStmt.java
index 46009bd1c09..8e1e589477d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackendsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackendsStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowBackendsStmt extends ShowStmt {
+public class ShowBackendsStmt extends ShowStmt implements NotFallbackInParser {
public ShowBackendsStmt() {
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
index 3c06a1da29e..a76857a8f8b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
@@ -37,7 +37,7 @@ import com.google.common.collect.ImmutableList;
import java.util.function.Predicate;
-public class ShowBackupStmt extends ShowStmt {
+public class ShowBackupStmt extends ShowStmt implements NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("JobId").add("SnapshotName").add("DbName").add("State").add("BackupObjs").add("CreateTime")
.add("SnapshotFinishedTime").add("UploadFinishedTime").add("FinishedTime").add("UnfinishedTasks")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBrokerStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBrokerStmt.java
index 2ef68cd149e..9f2b4d4ad5f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBrokerStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBrokerStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowBrokerStmt extends ShowStmt {
+public class ShowBrokerStmt extends ShowStmt implements NotFallbackInParser {
public ShowBrokerStmt() {
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBuildIndexStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBuildIndexStmt.java
index 5b02e306aa9..944365fb0d4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBuildIndexStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBuildIndexStmt.java
@@ -45,7 +45,7 @@ import java.util.List;
// syntax:
// SHOW BUILD INDEX [FROM db] [WHERE <condition>]
// [ORDER BY [DESC|ASC] [NULLS LAST | NULLS FIRST]]] [ LIMIT 1, 100]
-public class ShowBuildIndexStmt extends ShowStmt {
+public class ShowBuildIndexStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowBuildIndexStmt.class);
private String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
index 23b72938e96..847b015825d 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
@@ -40,7 +40,7 @@ import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
-public class ShowCacheHotSpotStmt extends ShowStmt {
+public class ShowCacheHotSpotStmt extends ShowStmt implements
NotFallbackInParser {
public static final ShowResultSetMetaData[] RESULT_SET_META_DATAS = {
ShowResultSetMetaData.builder()
.addColumn(new Column("cluster_id",
ScalarType.createType(PrimitiveType.BIGINT)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogRecycleBinStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogRecycleBinStmt.java
index f15c3657240..3a4a33e4d62 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogRecycleBinStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogRecycleBinStmt.java
@@ -36,7 +36,7 @@ import com.google.common.collect.ImmutableList;
import java.util.function.Predicate;
-public class ShowCatalogRecycleBinStmt extends ShowStmt {
+public class ShowCatalogRecycleBinStmt extends ShowStmt implements
NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("Type").add("Name").add("DbId").add("TableId").add("PartitionId").add("DropTime")
.add("DataSize").add("RemoteDataSize").build();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogStmt.java
index 191c5ba9a40..f1770859002 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCatalogStmt.java
@@ -25,7 +25,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
/**
* Statement for show all catalog or desc the specific catalog.
*/
-public class ShowCatalogStmt extends ShowStmt {
+public class ShowCatalogStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA_ALL =
ShowResultSetMetaData.builder().addColumn(new Column("CatalogId",
ScalarType.BIGINT))
.addColumn(new Column("CatalogName",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCharsetStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCharsetStmt.java
index 07e78fdf9ce..50725f69044 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCharsetStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCharsetStmt.java
@@ -21,7 +21,7 @@ import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowCharsetStmt extends ShowStmt {
+public class ShowCharsetStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Charset",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCloudWarmUpStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCloudWarmUpStmt.java
index d34c46d54a5..e91e9b7d6fe 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCloudWarmUpStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCloudWarmUpStmt.java
@@ -28,7 +28,7 @@ import com.google.common.collect.ImmutableList;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
-public class ShowCloudWarmUpStmt extends ShowStmt {
+public class ShowCloudWarmUpStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowCloudWarmUpStmt.class);
private Expr whereClause;
private boolean showAllJobs = false;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java
index 50bd36b1882..acb6d789f45 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java
@@ -33,7 +33,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
-public class ShowClusterStmt extends ShowStmt {
+public class ShowClusterStmt extends ShowStmt implements NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("cluster").add("is_current").add("users").build();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCollationStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCollationStmt.java
index df7e1f6a163..6fda6ab9220 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCollationStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCollationStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.PrimitiveType;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowCollationStmt extends ShowStmt {
+public class ShowCollationStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Collation",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnHistStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnHistStmt.java
index 88eb2445896..ae5010ffe0d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnHistStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnHistStmt.java
@@ -45,7 +45,7 @@ import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
-public class ShowColumnHistStmt extends ShowStmt {
+public class ShowColumnHistStmt extends ShowStmt implements
NotFallbackInParser {
private static final ImmutableList<String> TITLE_NAMES =
new ImmutableList.Builder<String>()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStatsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStatsStmt.java
index 833ca5e27a9..354b57bc55c 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStatsStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStatsStmt.java
@@ -50,7 +50,7 @@ import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
-public class ShowColumnStatsStmt extends ShowStmt {
+public class ShowColumnStatsStmt extends ShowStmt implements
NotFallbackInParser {
private static final ImmutableList<String> TABLE_COLUMN_TITLE_NAMES =
new ImmutableList.Builder<String>()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStmt.java
index 9af269104cc..cf9c4a27660 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStmt.java
@@ -32,7 +32,7 @@ import com.google.common.base.Strings;
import com.google.common.collect.Lists;
// SHOW COLUMNS
-public class ShowColumnStmt extends ShowStmt {
+public class ShowColumnStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Field", ScalarType.createVarchar(20)))
.addColumn(new Column("Type", ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConvertLSCStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConvertLSCStmt.java
index bab2e3b34b8..cedf3e2d246 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConvertLSCStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConvertLSCStmt.java
@@ -27,7 +27,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowConvertLSCStmt extends ShowStmt {
+public class ShowConvertLSCStmt extends ShowStmt implements
NotFallbackInParser {
private final String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCopyStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCopyStmt.java
index 0d4ba6a909e..50988fd6a47 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCopyStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCopyStmt.java
@@ -38,7 +38,7 @@ import java.util.Set;
//
// syntax:
// SHOW COPY [FROM db] [LIKE mask]
-public class ShowCopyStmt extends ShowLoadStmt {
+public class ShowCopyStmt extends ShowLoadStmt implements NotFallbackInParser {
private static final Logger LOG = LogManager.getLogger(ShowCopyStmt.class);
public ShowCopyStmt(String db, Expr labelExpr, List<OrderByElement>
orderByElements, LimitElement limitElement) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateCatalogStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateCatalogStmt.java
index 45208394eaf..f324b0701a8 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateCatalogStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateCatalogStmt.java
@@ -32,7 +32,7 @@ import com.google.common.base.Strings;
// Show create catalog statement
// Syntax:
// SHOW CREATE CATALOG catalogName
-public class ShowCreateCatalogStmt extends ShowStmt {
+public class ShowCreateCatalogStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Catalog",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
index b709be8d7e9..99cd1b33438 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
@@ -33,7 +33,7 @@ import com.google.common.base.Strings;
// Show create database statement
// Syntax:
// SHOW CREATE DATABASE db
-public class ShowCreateDbStmt extends ShowStmt {
+public class ShowCreateDbStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Database",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
index e1ff16ba8dd..b65f9318e58 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
@@ -33,7 +33,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowCreateFunctionStmt extends ShowStmt {
+public class ShowCreateFunctionStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Function Signature",
ScalarType.createVarchar(256)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMTMVStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMTMVStmt.java
index fb8e69e779a..215217f63bd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMTMVStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMTMVStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW CREATE Materialized View statement.
-public class ShowCreateMTMVStmt extends ShowStmt {
+public class ShowCreateMTMVStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Materialized View",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMaterializedViewStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMaterializedViewStmt.java
index f0c48520a5c..ad5469809cf 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMaterializedViewStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMaterializedViewStmt.java
@@ -36,7 +36,7 @@ import lombok.Getter;
**/
@AllArgsConstructor
@Getter
-public class ShowCreateMaterializedViewStmt extends ShowStmt {
+public class ShowCreateMaterializedViewStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateRepositoryStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateRepositoryStmt.java
index 9de7dd0e9ee..efd436ea240 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateRepositoryStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateRepositoryStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW CREATE REPOSITORY statement
-public class ShowCreateRepositoryStmt extends ShowStmt {
+public class ShowCreateRepositoryStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateTableStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateTableStmt.java
index 1a8ec38080f..9b60417c721 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateTableStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateTableStmt.java
@@ -31,7 +31,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW CREATE TABLE statement.
-public class ShowCreateTableStmt extends ShowStmt {
+public class ShowCreateTableStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Table",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataSkewStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataSkewStmt.java
index c1ccc521c3b..6db5aeaa9da 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataSkewStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataSkewStmt.java
@@ -31,7 +31,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
// show data skew from tbl [partition(p1, p2, ...)]
-public class ShowDataSkewStmt extends ShowStmt {
+public class ShowDataSkewStmt extends ShowStmt implements NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("PartitionName").add("BucketIdx").add("AvgRowCount").add("AvgDataSize")
.add("Graph").add("Percent")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataStmt.java
index 84ce67283ac..26b77e0b3d5 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataStmt.java
@@ -56,7 +56,7 @@ import java.util.SortedSet;
import java.util.TreeMap;
import java.util.TreeSet;
-public class ShowDataStmt extends ShowStmt {
+public class ShowDataStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData SHOW_DATABASE_DATA_META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("DbId",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataTypesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataTypesStmt.java
index 0ee95dd817e..31bc8f3f598 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataTypesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDataTypesStmt.java
@@ -31,7 +31,7 @@ import java.util.Collections;
import java.util.Comparator;
import java.util.List;
-public class ShowDataTypesStmt extends ShowStmt {
+public class ShowDataTypesStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbIdStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbIdStmt.java
index 967714e0fa2..6e800274817 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbIdStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbIdStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW DATABASE ID
-public class ShowDbIdStmt extends ShowStmt {
+public class ShowDbIdStmt extends ShowStmt implements NotFallbackInParser {
private long dbId;
public ShowDbIdStmt(long dbId) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbStmt.java
index c9606bc5bd2..aba12fbd0c6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDbStmt.java
@@ -29,7 +29,7 @@ import com.google.common.base.Strings;
import com.google.common.collect.Lists;
// Show database statement.
-public class ShowDbStmt extends ShowStmt {
+public class ShowDbStmt extends ShowStmt implements NotFallbackInParser {
private static final TableName TABLE_NAME = new
TableName(InternalCatalog.INTERNAL_CATALOG_NAME,
InfoSchemaDb.DATABASE_NAME, "schemata");
private static final String DB_COL = "Database";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDeleteStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDeleteStmt.java
index 85df0571899..dcf36d11609 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDeleteStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDeleteStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowDeleteStmt extends ShowStmt {
+public class ShowDeleteStmt extends ShowStmt implements NotFallbackInParser {
private String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDynamicPartitionStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDynamicPartitionStmt.java
index d8b0c177921..ef1d731d77b 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDynamicPartitionStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowDynamicPartitionStmt.java
@@ -26,7 +26,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowDynamicPartitionStmt extends ShowStmt {
+public class ShowDynamicPartitionStmt extends ShowStmt implements
NotFallbackInParser {
private String db;
private static final ShowResultSetMetaData
SHOW_DYNAMIC_PARTITION_META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
index 83358209c23..44ebc7b2b70 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowEncryptKeysStmt extends ShowStmt {
+public class ShowEncryptKeysStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("EncryptKey Name",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEnginesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEnginesStmt.java
index f6ff28a671c..86ac4af67fb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEnginesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEnginesStmt.java
@@ -21,7 +21,7 @@ import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowEnginesStmt extends ShowStmt {
+public class ShowEnginesStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Engine",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEventsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEventsStmt.java
index 4e47ac79dec..97ac779cd28 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEventsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEventsStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// Show Events statement
-public class ShowEventsStmt extends ShowStmt {
+public class ShowEventsStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Db", ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowExportStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowExportStmt.java
index 14b5d05537c..757eaf83bac 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowExportStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowExportStmt.java
@@ -40,7 +40,7 @@ import java.util.List;
//
// syntax:
// SHOW EXPORT [FROM db] [where ...]
-public class ShowExportStmt extends ShowStmt {
+public class ShowExportStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowExportStmt.class);
private String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFrontendsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFrontendsStmt.java
index b3b5808d945..d8b5c454ff9 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFrontendsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFrontendsStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
-public class ShowFrontendsStmt extends ShowStmt {
+public class ShowFrontendsStmt extends ShowStmt implements NotFallbackInParser
{
private String detail;
public ShowFrontendsStmt() {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
index 5abd18f7463..a994d0f6463 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
@@ -32,7 +32,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowFunctionsStmt extends ShowStmt {
+public class ShowFunctionsStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Signature",
ScalarType.createVarchar(256)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowGrantsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowGrantsStmt.java
index f78d4ca59fa..0439544ae0e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowGrantsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowGrantsStmt.java
@@ -43,7 +43,7 @@ import com.google.common.base.Preconditions;
//
// SHOW GRANTS;
// SHOW GRANTS FOR user@'xxx'
-public class ShowGrantsStmt extends ShowStmt {
+public class ShowGrantsStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowIndexStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowIndexStmt.java
index b35f2e77287..43f02f4426d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowIndexStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowIndexStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowIndexStmt extends ShowStmt {
+public class ShowIndexStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Table",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLastInsertStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLastInsertStmt.java
index 9ed0ebc6cd7..4ba3521d51c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLastInsertStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLastInsertStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW LAST INSERT
-public class ShowLastInsertStmt extends ShowStmt {
+public class ShowLastInsertStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("TransactionId",
ScalarType.createVarchar(128)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
index 490a5211321..78437cec796 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
@@ -24,7 +24,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
// deprecated stmt, use will be guided to a specific url to get profile from
// web browser
-public class ShowLoadProfileStmt extends ShowStmt {
+public class ShowLoadProfileStmt extends ShowStmt implements
NotFallbackInParser {
private String loadIdPath;
public ShowLoadProfileStmt(String path) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadStmt.java
index b08ef917ab3..760f70481fc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadStmt.java
@@ -42,7 +42,7 @@ import java.util.Set;
//
// syntax:
// SHOW LOAD [FROM db] [LIKE mask]
-public class ShowLoadStmt extends ShowStmt {
+public class ShowLoadStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG = LogManager.getLogger(ShowLoadStmt.class);
private String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadWarningsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadWarningsStmt.java
index 624fc0a402b..f034c32a496 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadWarningsStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadWarningsStmt.java
@@ -33,7 +33,7 @@ import java.net.MalformedURLException;
import java.net.URL;
// SHOW LOAD WARNINGS statement used to get error detail of src data.
-public class ShowLoadWarningsStmt extends ShowStmt {
+public class ShowLoadWarningsStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowLoadWarningsStmt.class);
private static final ShowResultSetMetaData META_DATA =
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowOpenTableStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowOpenTableStmt.java
index 7c7dd8a9253..3c2ae9f3795 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowOpenTableStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowOpenTableStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW OPEN TABLES
-public class ShowOpenTableStmt extends ShowStmt {
+public class ShowOpenTableStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Database",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionIdStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionIdStmt.java
index 5aca99da337..793a886ff31 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionIdStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionIdStmt.java
@@ -28,7 +28,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW PARTITION ID
-public class ShowPartitionIdStmt extends ShowStmt {
+public class ShowPartitionIdStmt extends ShowStmt implements
NotFallbackInParser {
private long partitionId;
public ShowPartitionIdStmt(long partitionId) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionsStmt.java
index 1c61018bc53..0be41ef60fa 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPartitionsStmt.java
@@ -54,7 +54,7 @@ import java.util.List;
import java.util.Map;
import java.util.Objects;
-public class ShowPartitionsStmt extends ShowStmt {
+public class ShowPartitionsStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowPartitionsStmt.class);
private static final String FILTER_PARTITION_ID = "PartitionId";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPluginsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPluginsStmt.java
index 249e49da28d..dc04e77d2ac 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPluginsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPluginsStmt.java
@@ -29,7 +29,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
// Show plugins statement.
// TODO(zhaochun): only for support MySQL
-public class ShowPluginsStmt extends ShowStmt {
+public class ShowPluginsStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Name",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPolicyStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPolicyStmt.java
index df413ee61e4..4c471fbcc42 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPolicyStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPolicyStmt.java
@@ -36,7 +36,7 @@ import org.apache.commons.lang3.StringUtils;
* syntax:
* SHOW ROW POLICY [FOR user｜ROLE role]
**/
-public class ShowPolicyStmt extends ShowStmt {
+public class ShowPolicyStmt extends ShowStmt implements NotFallbackInParser {
@Getter
private final PolicyTypeEnum type;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPrivilegesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPrivilegesStmt.java
index 31f2d0edeab..a053c9e327f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPrivilegesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPrivilegesStmt.java
@@ -21,7 +21,7 @@ import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowPrivilegesStmt extends ShowStmt {
+public class ShowPrivilegesStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA;
static {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcStmt.java
index bc7c70cdc79..0d154db6232 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcStmt.java
@@ -31,7 +31,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW PROC statement. Used to show proc information, only admin can use.
-public class ShowProcStmt extends ShowStmt {
+public class ShowProcStmt extends ShowStmt implements NotFallbackInParser {
private String path;
private ProcNodeInterface node;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcedureStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcedureStmt.java
index db7684591fd..960f54a2a8c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcedureStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcedureStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW PROCEDURE STATUS
-public class ShowProcedureStmt extends ShowStmt {
+public class ShowProcedureStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Db", ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcesslistStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcesslistStmt.java
index e602e85f499..a4fd6a183c0 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcesslistStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowProcesslistStmt.java
@@ -25,7 +25,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW PROCESSLIST statement.
// Used to show connection belong to this user.
-public class ShowProcesslistStmt extends ShowStmt {
+public class ShowProcesslistStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("CurrentConnected",
ScalarType.createVarchar(16)))
.addColumn(new Column("Id",
ScalarType.createType(PrimitiveType.BIGINT)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryProfileStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryProfileStmt.java
index 39d07743826..ad664652d53 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryProfileStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryProfileStmt.java
@@ -24,7 +24,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
// deprecated stmt, use will be guided to a specific url to get profile from
// web browser
-public class ShowQueryProfileStmt extends ShowStmt {
+public class ShowQueryProfileStmt extends ShowStmt implements
NotFallbackInParser {
private String queryIdPath;
public ShowQueryProfileStmt(String queryIdPath) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryStatsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryStatsStmt.java
index fee9809f96e..723a0ef8629 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryStatsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueryStatsStmt.java
@@ -39,7 +39,7 @@ import java.util.Arrays;
import java.util.List;
import java.util.Map;
-public class ShowQueryStatsStmt extends ShowStmt {
+public class ShowQueryStatsStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData
SHOW_QUERY_STATS_CATALOG_META_DATA = ShowResultSetMetaData.builder()
.addColumn(new Column("Database", ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaDistributionStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaDistributionStmt.java
index 58d2ac1052f..24ef8eddfc9 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaDistributionStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaDistributionStmt.java
@@ -32,7 +32,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
// show replica distribution from tbl [partition(p1, p2, ...)]
-public class ShowReplicaDistributionStmt extends ShowStmt {
+public class ShowReplicaDistributionStmt extends ShowStmt implements
NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("BackendId").add("ReplicaNum").add("ReplicaSize")
.add("NumGraph").add("NumPercent")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
index 2a1f96fed96..44215ed1150 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
@@ -36,7 +36,7 @@ import com.google.common.collect.Lists;
import java.util.List;
-public class ShowReplicaStatusStmt extends ShowStmt {
+public class ShowReplicaStatusStmt extends ShowStmt implements
NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("TabletId").add("ReplicaId").add("BackendId").add("Version").add("LastFailedVersion")
.add("LastSuccessVersion").add("CommittedVersion").add("SchemaHash").add("VersionNum")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRepositoriesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRepositoriesStmt.java
index 6e5166a5c87..6dc6e3bf0bb 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRepositoriesStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRepositoriesStmt.java
@@ -29,7 +29,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.collect.ImmutableList;
-public class ShowRepositoriesStmt extends ShowStmt {
+public class ShowRepositoriesStmt extends ShowStmt implements
NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("RepoId").add("RepoName").add("CreateTime").add("IsReadOnly").add("Location")
.add("Broker").add("Type").add("ErrMsg")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowResourcesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowResourcesStmt.java
index 97393334679..9289d903627 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowResourcesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowResourcesStmt.java
@@ -40,7 +40,7 @@ import java.util.Set;
//
// syntax:
// SHOW RESOURCES [LIKE mask]
-public class ShowResourcesStmt extends ShowStmt {
+public class ShowResourcesStmt extends ShowStmt implements NotFallbackInParser
{
private static final Logger LOG =
LogManager.getLogger(ShowResourcesStmt.class);
private String pattern;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
index 26016be7814..2ffa8607fbd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
@@ -38,7 +38,7 @@ import com.google.common.collect.ImmutableList;
import java.util.List;
import java.util.function.Predicate;
-public class ShowRestoreStmt extends ShowStmt {
+public class ShowRestoreStmt extends ShowStmt implements NotFallbackInParser {
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
.add("JobId").add("Label").add("Timestamp").add("DbName").add("State")
.add("AllowLoad").add("ReplicationNum").add("ReplicaAllocation").add("ReserveReplica")
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRolesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRolesStmt.java
index bbb66b27443..1f3f19a6d29 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRolesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRolesStmt.java
@@ -27,7 +27,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowRolesStmt extends ShowStmt {
+public class ShowRolesStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA;
static {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRollupStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRollupStmt.java
index 2684f3bcea8..f7f65800b58 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRollupStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRollupStmt.java
@@ -31,7 +31,7 @@ import com.google.common.base.Strings;
//
// Syntax:
// SHOW ROLLUP { FROM | IN } table [ FROM db ]
-public class ShowRollupStmt extends ShowStmt {
+public class ShowRollupStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Table",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
index ad8c57b7a47..5a227f96eb4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
@@ -30,7 +30,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowSmallFilesStmt extends ShowStmt {
+public class ShowSmallFilesStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Id", ScalarType.createVarchar(32)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSnapshotStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSnapshotStmt.java
index 83465a34600..6a736499d87 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSnapshotStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSnapshotStmt.java
@@ -32,7 +32,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
import com.google.common.collect.ImmutableList;
-public class ShowSnapshotStmt extends ShowStmt {
+public class ShowSnapshotStmt extends ShowStmt implements NotFallbackInParser {
public enum SnapshotType {
REMOTE,
LOCAL
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSqlBlockRuleStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSqlBlockRuleStmt.java
index c487e1c7978..ccf2b1ee6bf 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSqlBlockRuleStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSqlBlockRuleStmt.java
@@ -36,7 +36,7 @@ import org.apache.commons.lang3.StringUtils;
show sql_block_rule
show sql_block_rule for rule_name
*/
-public class ShowSqlBlockRuleStmt extends ShowStmt {
+public class ShowSqlBlockRuleStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStageStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStageStmt.java
index 09626911c1e..eac5b4aec83 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStageStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStageStmt.java
@@ -30,7 +30,7 @@ import org.apache.logging.log4j.Logger;
//
// syntax:
// SHOW STAGES
-public class ShowStageStmt extends ShowStmt {
+public class ShowStageStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowStageStmt.class);
private static final String NAME_COL = "StageName";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStatusStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStatusStmt.java
index a6276a88d4e..abce39aec6f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStatusStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStatusStmt.java
@@ -23,7 +23,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
// Show Status statement
// TODO(zhaochun): Add status information.
-public class ShowStatusStmt extends ShowStmt {
+public class ShowStatusStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Variable_name",
ScalarType.createVarchar(20)))
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStmt.java
index 9be50ee9dbd..92ed01acdfc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStmt.java
@@ -20,7 +20,7 @@ package org.apache.doris.analysis;
import org.apache.doris.common.AnalysisException;
import org.apache.doris.qe.ShowResultSetMetaData;
-public abstract class ShowStmt extends StatementBase {
+public abstract class ShowStmt extends StatementBase implements
NotFallbackInParser {
public abstract ShowResultSetMetaData getMetaData();
public SelectStmt toSelectStmt(Analyzer analyzer) throws AnalysisException
{
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStoragePolicyUsingStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStoragePolicyUsingStmt.java
index 56598a194ee..b6a8e367124 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStoragePolicyUsingStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStoragePolicyUsingStmt.java
@@ -34,7 +34,7 @@ import lombok.Getter;
* syntax:
* SHOW STORAGE POLICY USING [for policy_name]
**/
-public class ShowStoragePolicyUsingStmt extends ShowStmt {
+public class ShowStoragePolicyUsingStmt extends ShowStmt implements
NotFallbackInParser {
public static final ShowResultSetMetaData RESULT_META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStorageVaultStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStorageVaultStmt.java
index 1cd1d06a149..f6124c4d201 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStorageVaultStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStorageVaultStmt.java
@@ -31,7 +31,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
* syntax:
* SHOW STORAGE VAULT
**/
-public class ShowStorageVaultStmt extends ShowStmt {
+public class ShowStorageVaultStmt extends ShowStmt implements
NotFallbackInParser {
private final String stmt = "SHOW STORAGE VAULT";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStreamLoadStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStreamLoadStmt.java
index ae133aa2a23..92b67e6cc36 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStreamLoadStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStreamLoadStmt.java
@@ -41,7 +41,7 @@ import java.util.List;
//
// syntax:
// SHOW STREAM LOAD [FROM db] [LIKE mask]
-public class ShowStreamLoadStmt extends ShowStmt {
+public class ShowStreamLoadStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowStreamLoadStmt.class);
public enum StreamLoadState {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSyncJobStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSyncJobStmt.java
index f0671f8afe0..17a31fa1e16 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSyncJobStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSyncJobStmt.java
@@ -37,7 +37,7 @@ import org.apache.logging.log4j.Logger;
//
// syntax:
// SHOW SYNC JOB [FROM db]
-public class ShowSyncJobStmt extends ShowStmt {
+public class ShowSyncJobStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowSyncJobStmt.class);
public static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableCreationStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableCreationStmt.java
index d6bd9d0ea64..500265d45c6 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableCreationStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableCreationStmt.java
@@ -32,7 +32,7 @@ import com.google.common.base.Strings;
* Syntax:
* SHOW TABLE CREATION [FROM db] [LIKE mask]
*/
-public class ShowTableCreationStmt extends ShowStmt {
+public class ShowTableCreationStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableIdStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableIdStmt.java
index fc07f1c6722..d5830489645 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableIdStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableIdStmt.java
@@ -29,7 +29,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
// SHOW TABLE ID
-public class ShowTableIdStmt extends ShowStmt {
+public class ShowTableIdStmt extends ShowStmt implements NotFallbackInParser {
private long tableId;
public ShowTableIdStmt(long tableId) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatsStmt.java
index 36a0e9a5872..b1346af7928 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatsStmt.java
@@ -49,7 +49,7 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
-public class ShowTableStatsStmt extends ShowStmt {
+public class ShowTableStatsStmt extends ShowStmt implements
NotFallbackInParser {
private static final ImmutableList<String> TABLE_TITLE_NAMES =
new ImmutableList.Builder<String>()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
index 20e87908268..296eb628da2 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
@@ -34,7 +34,7 @@ import com.google.common.base.Strings;
import com.google.common.collect.Lists;
// SHOW TABLE STATUS
-public class ShowTableStatusStmt extends ShowStmt {
+public class ShowTableStatusStmt extends ShowStmt implements
NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Name", ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStmt.java
index f3e12f1aa92..92c5f34435f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStmt.java
@@ -33,7 +33,7 @@ import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
// SHOW TABLES
-public class ShowTableStmt extends ShowStmt {
+public class ShowTableStmt extends ShowStmt implements NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowTableStmt.class);
private static final String NAME_COL_PREFIX = "Tables_in_";
private static final String TYPE_COL = "Table_type";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStmt.java
index 71ba4e2be13..646d6a80639 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStmt.java
@@ -37,7 +37,7 @@ import com.google.common.base.Strings;
import java.util.ArrayList;
import java.util.List;
-public class ShowTabletStmt extends ShowStmt {
+public class ShowTabletStmt extends ShowStmt implements NotFallbackInParser {
private TableName dbTableName;
private String dbName;
private String tableName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStorageFormatStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStorageFormatStmt.java
index 9d0f3b88e6c..cf76ee504ee 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStorageFormatStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStorageFormatStmt.java
@@ -27,7 +27,7 @@ import org.apache.doris.mysql.privilege.PrivPredicate;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowTabletStorageFormatStmt extends ShowStmt {
+public class ShowTabletStorageFormatStmt extends ShowStmt implements
NotFallbackInParser {
private boolean verbose;
public ShowTabletStorageFormatStmt(boolean verbose) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletsBelongStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletsBelongStmt.java
index 3819541fea9..81d9d6d5017 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletsBelongStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletsBelongStmt.java
@@ -36,7 +36,7 @@ import java.util.List;
* syntax:
* SHOW TABLETS BELONG tablet_ids
*/
-public class ShowTabletsBelongStmt extends ShowStmt {
+public class ShowTabletsBelongStmt extends ShowStmt implements
NotFallbackInParser {
private List<Long> tabletIds;
private static final ImmutableList<String> TITLE_NAMES = new
ImmutableList.Builder<String>()
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTransactionStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTransactionStmt.java
index 3d5d03bdf8f..cd7d2ca5b01 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTransactionStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTransactionStmt.java
@@ -37,7 +37,7 @@ import org.apache.logging.log4j.Logger;
// syntax:
// SHOW TRANSACTION WHERE id=123
-public class ShowTransactionStmt extends ShowStmt {
+public class ShowTransactionStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowTransactionStmt.class);
private String dbName;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashDiskStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashDiskStmt.java
index f5fad57d0f5..7fb15eae663 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashDiskStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashDiskStmt.java
@@ -32,7 +32,7 @@ import org.apache.doris.system.Backend;
import com.google.common.collect.ImmutableMap;
-public class ShowTrashDiskStmt extends ShowStmt {
+public class ShowTrashDiskStmt extends ShowStmt implements NotFallbackInParser
{
private Backend backend;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashStmt.java
index 3071a657c53..e8e301193bc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashStmt.java
@@ -34,7 +34,7 @@ import com.google.common.collect.Lists;
import java.util.List;
-public class ShowTrashStmt extends ShowStmt {
+public class ShowTrashStmt extends ShowStmt implements NotFallbackInParser {
private List<Backend> backends = Lists.newArrayList();
public ShowTrashStmt() throws AnalysisException {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTriggersStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTriggersStmt.java
index e903d2387ee..de9cdf76816 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTriggersStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTriggersStmt.java
@@ -21,7 +21,7 @@ import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowTriggersStmt extends ShowStmt {
+public class ShowTriggersStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Trigger",
ScalarType.createVarchar(64)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTypeCastStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTypeCastStmt.java
index c88c39a03db..8ddf1a3d07f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTypeCastStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTypeCastStmt.java
@@ -27,7 +27,7 @@ import org.apache.doris.qe.ShowResultSetMetaData;
import com.google.common.base.Strings;
-public class ShowTypeCastStmt extends ShowStmt {
+public class ShowTypeCastStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Origin Type",
ScalarType.createVarchar(32)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowUserPropertyStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowUserPropertyStmt.java
index 7521e7497bc..76a9b9a9b4f 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowUserPropertyStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowUserPropertyStmt.java
@@ -46,7 +46,7 @@ import java.util.Set;
// Show Property Stmt
// syntax:
// SHOW [ALL] PROPERTY [FOR user] [LIKE key pattern]
-public class ShowUserPropertyStmt extends ShowStmt {
+public class ShowUserPropertyStmt extends ShowStmt implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(ShowUserPropertyStmt.class);
private String user;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowVariablesStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowVariablesStmt.java
index efe36311ca1..f398f021dc2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowVariablesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowVariablesStmt.java
@@ -28,7 +28,7 @@ import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
// Show variables statement.
-public class ShowVariablesStmt extends ShowStmt {
+public class ShowVariablesStmt extends ShowStmt implements NotFallbackInParser
{
private static final Logger LOG =
LogManager.getLogger(ShowVariablesStmt.class);
private static final String NAME_COL = "Variable_name";
private static final String VALUE_COL = "Value";
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowViewStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowViewStmt.java
index 67c77664ccc..f8cf26ed1bd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowViewStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowViewStmt.java
@@ -43,7 +43,7 @@ import java.util.Set;
//
// Syntax:
// SHOW VIEW { FROM | IN } table [ FROM db ]
-public class ShowViewStmt extends ShowStmt {
+public class ShowViewStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("View",
ScalarType.createVarchar(30)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWarningStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWarningStmt.java
index 7de4525ac2d..3018e9e56fd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWarningStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWarningStmt.java
@@ -22,7 +22,7 @@ import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
// Show Warning stmt
-public class ShowWarningStmt extends ShowStmt {
+public class ShowWarningStmt extends ShowStmt implements NotFallbackInParser {
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("Level",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWhiteListStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWhiteListStmt.java
index 43609d235cf..42682a57808 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWhiteListStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWhiteListStmt.java
@@ -21,7 +21,7 @@ import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.qe.ShowResultSetMetaData;
-public class ShowWhiteListStmt extends ShowStmt {
+public class ShowWhiteListStmt extends ShowStmt implements NotFallbackInParser
{
private static final ShowResultSetMetaData META_DATA =
ShowResultSetMetaData.builder()
.addColumn(new Column("user_name",
ScalarType.createVarchar(20)))
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadGroupsStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadGroupsStmt.java
index c802411be81..bb097e25a7f 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadGroupsStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadGroupsStmt.java
@@ -25,7 +25,7 @@ import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSetMetaData;
import org.apache.doris.resource.workloadgroup.WorkloadGroupMgr;
-public class ShowWorkloadGroupsStmt extends ShowStmt {
+public class ShowWorkloadGroupsStmt extends ShowStmt implements
NotFallbackInParser {
private String pattern;
// TODO: not supported yet
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionStmt.java
index 60c8d040f72..a1ad0ed2ed7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionStmt.java
@@ -20,7 +20,7 @@ package org.apache.doris.analysis;
import org.apache.doris.common.AnalysisException;
import org.apache.doris.common.UserException;
-public class TransactionStmt extends StatementBase {
+public class TransactionStmt extends StatementBase implements
NotFallbackInParser {
@Override
public RedirectStatus getRedirectStatus() {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/analysis/UseCloudClusterStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/analysis/UseCloudClusterStmt.java
index de7fdf213a5..40bd2dbebc6 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/analysis/UseCloudClusterStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/analysis/UseCloudClusterStmt.java
@@ -18,6 +18,7 @@
package org.apache.doris.cloud.analysis;
import org.apache.doris.analysis.Analyzer;
+import org.apache.doris.analysis.NotFallbackInParser;
import org.apache.doris.analysis.RedirectStatus;
import org.apache.doris.analysis.ResourceTypeEnum;
import org.apache.doris.analysis.StatementBase;
@@ -39,7 +40,7 @@ import org.apache.logging.log4j.Logger;
/**
* Representation of a use cluster statement.
*/
-public class UseCloudClusterStmt extends StatementBase {
+public class UseCloudClusterStmt extends StatementBase implements
NotFallbackInParser {
private static final Logger LOG =
LogManager.getLogger(UseCloudClusterStmt.class);
private String cluster;
private String database;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
