diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 9d005cdb07a79d734c4f05126febc14d6fc8d624..f94c65834dd0c4154f5f2274163df7c878f9a7ac 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -6333,6 +6333,7 @@ int32_t qKillQuery(qinfo_t qinfo) {
     return TSDB_CODE_QRY_INVALID_QHANDLE;
   }
 
+  sem_post(&pQInfo->dataReady);
   setQueryKilled(pQInfo);
   return TSDB_CODE_SUCCESS;
 }