diff --git a/src/emqx_misc.erl b/src/emqx_misc.erl
index 5abec7d98..fc4ee842a 100644
--- a/src/emqx_misc.erl
+++ b/src/emqx_misc.erl
@@ -83,7 +83,7 @@ pipeline([Fun|More], Input, State) ->
             {error, Reason, NState}
     catch
         Error:Reason:Stacktrace ->
-            ?LOG("pipeline ~p failed: ~p, stacktrace: ~p",
+            ?LOG(error, "pipeline ~p failed: ~p, stacktrace: ~p",
                 [{Fun, Input, State}, {Error, Reason}, Stacktrace]),
             {error, Reason, State}
     end.