diff --git a/src/client/src/taos.def b/src/client/src/taos.def
index b3f232bb7b33b93c50dfb35536b4ebe6e633e95c..7a4e842d0c7b4ba4ff9d0e87ebd4c95f734260ea 100644
--- a/src/client/src/taos.def
+++ b/src/client/src/taos.def
@@ -41,8 +41,6 @@ taos_fetch_rows_a
 taos_subscribe
 taos_consume
 taos_unsubscribe
-taos_open_stream
-taos_close_stream
 taos_load_table_info
 taos_data_type
 taos_stmt_set_sub_tbname
@@ -57,4 +55,4 @@ taos_print_row_ex
 taos_stmt_affected_rows
 taos_is_update_query
 taos_reset_current_db
-taos_parse_time
\ No newline at end of file
+taos_parse_time
diff --git a/src/client/src/tscProfile.c b/src/client/src/tscProfile.c
index bfc3b9f0be1cedfe1e7c3d66f1fa3ab16f5d37f3..537e4eb35a6e6b8db2587eb66d420e2f9d77e5b6 100644
--- a/src/client/src/tscProfile.c
+++ b/src/client/src/tscProfile.c
@@ -24,6 +24,7 @@
 #include "taos.h"
 #include "tscUtil.h"
 
+void taos_close_stream(TAOS_STREAM *handle);
 void  tscSaveSlowQueryFp(void *handle, void *tmrId);
 TAOS *tscSlowQueryConn = NULL;
 bool  tscSlowQueryConnInitialized = false;
diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index e2779854e096fcea454db76c26ff365a9f6e1309..0ed4c0a270ca675dfc445f387ad48de5171df7d9 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -26,6 +26,7 @@
 #include "tscProfile.h"
 #include "tscSubquery.h"
 
+void taos_close_stream(TAOS_STREAM *handle);
 static void tscProcessStreamQueryCallback(void *param, TAOS_RES *tres, int numOfRows);
 static void tscProcessStreamRetrieveResult(void *param, TAOS_RES *res, int numOfRows);
 static void tscSetNextLaunchTimer(SSqlStream *pStream, SSqlObj *pSql);
diff --git a/src/cq/src/cqMain.c b/src/cq/src/cqMain.c
index a1affc0869dca0a177ffafc6ab3309328652a696..e0576e2d8b5b23f9932b8893f2cd2d1db2d21115 100644
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -54,6 +54,7 @@ typedef struct SCqObj {
   SCqContext *   pContext;
 } SCqObj;
 
+void taos_close_stream(TAOS_STREAM *handle);
 static void cqProcessStreamRes(void *param, TAOS_RES *tres, TAOS_ROW row); 
 static void cqCreateStream(SCqContext *pContext, SCqObj *pObj);
 
diff --git a/src/inc/taos.h b/src/inc/taos.h
index 80fbe4ef0846867d77d34ed9384e7bd3da9fe4db..481fc0f21d6819a623bcb6c947fcfa69086597bc 100644
--- a/src/inc/taos.h
+++ b/src/inc/taos.h
@@ -206,10 +206,6 @@ DLL_EXPORT TAOS_SUB *taos_subscribe(TAOS* taos, int restart, const char* topic,
 DLL_EXPORT TAOS_RES *taos_consume(TAOS_SUB *tsub);
 DLL_EXPORT void      taos_unsubscribe(TAOS_SUB *tsub, int keepProgress);
 
-DLL_EXPORT TAOS_STREAM *taos_open_stream(TAOS *taos, const char *sql, void (*fp)(void *param, TAOS_RES *, TAOS_ROW row),
-                              int64_t stime, void *param, void (*callback)(void *));
-DLL_EXPORT void taos_close_stream(TAOS_STREAM *tstr);
-
 DLL_EXPORT int taos_load_table_info(TAOS *taos, const char* tableNameList);
 
 DLL_EXPORT TAOS_RES *taos_schemaless_insert(TAOS* taos, char* lines[], int numLines, int protocol, int precision);