diff --git a/backend/apps/datasource/crud/datasource.py b/backend/apps/datasource/crud/datasource.py
index eb62f54a..2de6a587 100644
--- a/backend/apps/datasource/crud/datasource.py
+++ b/backend/apps/datasource/crud/datasource.py
@@ -293,6 +293,10 @@ def preview(session: SessionDep, current_user: CurrentUser, id: int, data: Table
         sql = f"""SELECT "{'", "'.join(fields)}" FROM "{conf.dbSchema}"."{data.table.table_name}" 
             {where} 
             LIMIT 100"""
+    elif ds.type == "es":
+        sql = f"""SELECT "{'", "'.join(fields)}" FROM "{data.table.table_name}" 
+            {where} 
+            LIMIT 100"""
     return exec_sql(ds, sql, True)