diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl
index 5edee241f..d301ce03c 100644
--- a/apps/emqx_resource/src/emqx_resource_worker.erl
+++ b/apps/emqx_resource/src/emqx_resource_worker.erl
@@ -1021,7 +1021,7 @@ queue_count(Q) ->
 disk_queue_dir(Id, Index) ->
     QDir0 = binary_to_list(Id) ++ "_" ++ integer_to_list(Index),
     QDir = sanitizy_file_path(QDir0),
-    filename:join([emqx:data_dir(), "resource_worker", node(), QDir]).
+    filename:join([emqx:data_dir(), "bufs", node(), QDir]).
 
 sanitizy_file_path(Filepath) ->
     iolist_to_binary(string:replace(Filepath, ":", "_", all)).