From d63d942f8a8cf5eb54fec1be3acadd522aa9aa85 Mon Sep 17 00:00:00 2001
From: Yongqiang YANG <98214048+dataroaring@users.noreply.github.com>
Date: Wed, 10 Jul 2024 22:15:24 +0800
Subject: [PATCH] add comment

---
 .../java/org/apache/doris/qe/StmtExecutor.java   | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index b9c003eff93b03..d92077093fd892 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -725,6 +725,12 @@ private void executeByNereids(TUniqueId queryId) throws Exception {
                     return;
                 }
             }
+            
+            // Query following createting table would throw table not exist error.
+            // For example.
+            // t1: client issues create table to master fe
+            // t2: client issues query sql to observer fe, the query would fail due to not exist table in plan phase.
+            // t3: observer fe receive editlog creating the table from the master fe
             syncJournalIfNeeded();
             try {
                 ((Command) logicalPlan).run(context, this);
@@ -760,6 +766,11 @@ private void executeByNereids(TUniqueId queryId) throws Exception {
         } else {
             context.getState().setIsQuery(true);
             // create plan
+            // Query following createting table would throw table not exist error.
+            // For example.
+            // t1: client issues create table to master fe
+            // t2: client issues query sql to observer fe, the query would fail due to not exist table in plan phase.
+            // t3: observer fe receive editlog creating the table from the master fe
             syncJournalIfNeeded();
             planner = new NereidsPlanner(statementContext);
             if (context.getSessionVariable().isEnableMaterializedViewRewrite()) {
@@ -956,6 +967,11 @@ public void executeByLegacy(TUniqueId queryId) throws Exception {
                     }
                 }
             } else {
+                // Query following createting table would throw table not exist error.
+                // For example.
+                // t1: client issues create table to master fe
+                // t2: client issues query sql to observer fe, the query would fail due to not exist table in plan phase.
+                // t3: observer fe receive editlog creating the table from the master fe
                 syncJournalIfNeeded();
                 analyzer = new Analyzer(context.getEnv(), context);
                 parsedStmt.analyze(analyzer);