diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 831f0f3485cbca671a392a9bd087c6d731cd214e..77e7321d3d96ee77e455ede94b9ee8057b6f4312 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -6552,7 +6552,8 @@ void* qOpenQueryMgmt(int32_t vgId) {
 }
 
 static void queryMgmtKillQueryFn(void* handle) {
-  qKillQuery(handle);
+  void** fp = (void**)handle;
+  qKillQuery(*fp);
 }
 
 void qQueryMgmtNotifyClosed(void* pQMgmt) {