From 276e631e9cea58dc7fb1df8e88219777bece6862 Mon Sep 17 00:00:00 2001 From: Yongqiang YANG <98214048+dataroaring@users.noreply.github.com> Date: Mon, 15 May 2023 21:59:44 +0800 Subject: [PATCH] [chore](ddlExecutor) log class of unknown stmt in DdlExecutor (#19631) * [chore](ddlExecutor) log class of unknown stmt in DdlExecutor --- .../src/main/java/org/apache/doris/qe/DdlExecutor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/DdlExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/DdlExecutor.java index 356939ea33..4ac228cf10 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/DdlExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/DdlExecutor.java @@ -120,10 +120,15 @@ import org.apache.doris.load.sync.SyncJobManager; import org.apache.doris.persist.CleanQueryStatsInfo; import org.apache.doris.statistics.StatisticsRepository; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; + /** * Use for execute ddl. **/ public class DdlExecutor { + private static final Logger LOG = LogManager.getLogger(DdlExecutor.class); + /** * Execute ddl. **/ @@ -348,6 +353,7 @@ public class DdlExecutor { } env.cleanQueryStats(cleanQueryStatsInfo); } else { + LOG.warn("Unkown statement " + ddlStmt.getClass()); throw new DdlException("Unknown statement."); } }