diff --git a/dsRag/StartEs.py b/dsRag/StartEs.py
index 33f56f02..2dfd8d78 100644
--- a/dsRag/StartEs.py
+++ b/dsRag/StartEs.py
@@ -257,7 +257,7 @@ async def rag_stream(request: Request):
     """RAG+ALiYun接口"""
     async for chunk in generate_stream(
             request.app.state.aliyun_util,
-            request.app.state.milvus_pool,
+            request.app.state.es_pool,
             request.app.state.collection_manager,
             query_request.query,
             query_request.documents