diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
index a9e502950ac773..1c5efa69308f9a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
@@ -61,6 +61,9 @@ public void execute() throws Exception {
     
     // Send request to Master
     private void forward() throws Exception {
+        if (!ctx.getCatalog().isReady()) {
+            throw new Exception("Node catalog is not ready, please wait for a while.");
+        }
         String masterHost = ctx.getCatalog().getMasterIp();
         int masterRpcPort = ctx.getCatalog().getMasterRpcPort();
         TNetworkAddress thriftAddress = new TNetworkAddress(masterHost, masterRpcPort);