diff --git a/apps/emqx_bridge_cassandra/test/emqx_bridge_cassandra_SUITE.erl b/apps/emqx_bridge_cassandra/test/emqx_bridge_cassandra_SUITE.erl
index 77aec7d99..09deaa699 100644
--- a/apps/emqx_bridge_cassandra/test/emqx_bridge_cassandra_SUITE.erl
+++ b/apps/emqx_bridge_cassandra/test/emqx_bridge_cassandra_SUITE.erl
@@ -302,9 +302,7 @@ query_resource(Config, Request) ->
     Name = ?config(cassa_name, Config),
     BridgeType = ?config(cassa_bridge_type, Config),
     BridgeV2Id = emqx_bridge_v2:id(BridgeType, Name),
-    ConnectorResId = emqx_connector_resource:resource_id(
-        cassandra, <<"connector_emqx_bridge_cassandra_SUITE">>
-    ),
+    ConnectorResId = emqx_connector_resource:resource_id(BridgeType, Name),
     emqx_resource:query(BridgeV2Id, Request, #{
         timeout => 1_000, connector_resource_id => ConnectorResId
     }).
@@ -315,9 +313,7 @@ query_resource_async(Config, Request) ->
     Ref = alias([reply]),
     AsyncReplyFun = fun(Result) -> Ref ! {result, Ref, Result} end,
     BridgeV2Id = emqx_bridge_v2:id(BridgeType, Name),
-    ConnectorResId = emqx_connector_resource:resource_id(
-        cassandra, <<"connector_emqx_bridge_cassandra_SUITE">>
-    ),
+    ConnectorResId = emqx_connector_resource:resource_id(BridgeType, Name),
     Return = emqx_resource:query(BridgeV2Id, Request, #{
         timeout => 500,
         async_reply_fun => {AsyncReplyFun, []},