diff --git a/apps/emqx_oracle/src/emqx_oracle.erl b/apps/emqx_oracle/src/emqx_oracle.erl
index e1ac846fa..ddae7ec8f 100644
--- a/apps/emqx_oracle/src/emqx_oracle.erl
+++ b/apps/emqx_oracle/src/emqx_oracle.erl
@@ -186,35 +186,6 @@ on_get_channel_status(
             %% do not log error, it is logged in prepare_sql_to_conn
             connecting
     end.
-% #{stream_name := StreamName} = maps:get(ChannelId, Channels),
-% case
-%     emqx_resource_pool:health_check_workers(
-%         PoolName,
-%         {emqx_bridge_kinesis_connector_client, connection_status, [StreamName]},
-%         ?HEALTH_CHECK_TIMEOUT,
-%         #{return_values => true}
-%     )
-% of
-%     {ok, Values} ->
-%         AllOk = lists:all(fun(S) -> S =:= {ok, ?status_connected} end, Values),
-%         case AllOk of
-%             true ->
-%                 ?status_connected;
-%             false ->
-%                 Unhealthy = lists:any(fun(S) -> S =:= {error, unhealthy_target} end, Values),
-%                 case Unhealthy of
-%                     true -> {?status_disconnected, {unhealthy_target, ?TOPIC_MESSAGE}};
-%                     false -> ?status_disconnected
-%                 end
-%         end;
-%     {error, Reason} ->
-%         ?SLOG(error, #{
-%             msg => "kinesis_producer_get_status_failed",
-%             state => State,
-%             reason => Reason
-%         }),
-%         ?status_disconnected
-% end.
 
 on_get_channels(ResId) ->
     emqx_bridge_v2:get_channels_for_connector(ResId).
@@ -387,16 +358,6 @@ do_check_prepares(
         ok,
         Workers
     ).
-% case prepare_sql(Prepares, PoolName, TokensMap) of
-%     %% remove the error
-%     {ok, Sts} ->
-%         {ok, State#{prepare_sql => Sts}};
-%     {error, undefined_table} ->
-%         %% indicate the error
-%         {error, {undefined_table, State#{prepare_sql => {error, Prepares}}}};
-%     {error, _Reason} = Error ->
-%         Error
-% end.
 
 %% ===================================================================