diff --git a/apps/emqx_connector/src/emqx_connector_mongo.erl b/apps/emqx_connector/src/emqx_connector_mongo.erl
index 84aabcd48..4fa7449d5 100644
--- a/apps/emqx_connector/src/emqx_connector_mongo.erl
+++ b/apps/emqx_connector/src/emqx_connector_mongo.erl
@@ -186,23 +186,13 @@ on_stop(InstId, #{poolname := PoolName}) ->
     }),
     emqx_plugin_libs_pool:stop_pool(PoolName).
 
-on_query(InstId,
-         {Action, Collection, Filter, Projector},
-         AfterQuery,
-         #{poolname := PoolName} = State) ->
-    Request = {Action, Collection, Filter, Projector},
-    ?TRACE("QUERY", "mongodb_connector_received",
-        #{request => Request, connector => InstId, state => State}),
-    case ecpool:pick_and_do(PoolName,
-                            {?MODULE, mongo_query, [Action, Collection, Filter, Projector]},
-                            no_handover) of
 on_query(
     InstId,
     {Action, Collection, Filter, Projector},
     AfterQuery,
     #{poolname := PoolName} = State
 ) ->
-    Request = {Action, Collection, Selector, Projector},
+    Request = {Action, Collection, Filter, Projector},
     ?TRACE(
         "QUERY",
         "mongodb_connector_received",
@@ -211,7 +201,7 @@ on_query(
     case
         ecpool:pick_and_do(
             PoolName,
-            {?MODULE, mongo_query, [Action, Collection, Selector, Projector]},
+            {?MODULE, mongo_query, [Action, Collection, Filter, Projector]},
             no_handover
         )
     of