From 7d2c336ab7427e6b909b66f2e9f1452c3ef3baf3 Mon Sep 17 00:00:00 2001 From: firest Date: Sun, 23 Apr 2023 15:31:08 +0800 Subject: [PATCH] fix(resource): make sure resource will not crash when stopping --- apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl b/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl index a00dcdcd2..ae30c3927 100644 --- a/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl +++ b/apps/emqx_resource/src/emqx_resource_buffer_worker_sup.erl @@ -141,9 +141,5 @@ ensure_disk_queue_dir_absent(ResourceId, Index) -> ok. ensure_worker_pool_removed(ResId) -> - try - gproc_pool:delete(ResId) - catch - error:badarg -> ok - end, + gproc_pool:force_delete(ResId), ok.