diff --git a/headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/calcite/sql/node/DataSourceNode.java b/headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/calcite/sql/node/DataSourceNode.java
index c1b6fedaf..081e7285f 100644
--- a/headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/calcite/sql/node/DataSourceNode.java
+++ b/headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/calcite/sql/node/DataSourceNode.java
@@ -67,8 +67,8 @@ public class DataSourceNode extends SemanticNode {
             String tb = entry.getKey();
             String db = "";
             if (entry.getKey().indexOf(".") > 0) {
-                db = entry.getKey().substring(0, entry.getKey().indexOf("."));
-                tb = entry.getKey().substring(entry.getKey().indexOf(".") + 1);
+                db = entry.getKey().substring(0, entry.getKey().lastIndexOf("."));
+                tb = entry.getKey().substring(entry.getKey().lastIndexOf(".") + 1);
             }
             addSchemaTable(scope, datasource, db, tb, entry.getValue());
         }