diff --git a/be/src/agent/agent_server.cpp b/be/src/agent/agent_server.cpp
index e94d4c349a9d4e..e7217cdcff0bf5 100644
--- a/be/src/agent/agent_server.cpp
+++ b/be/src/agent/agent_server.cpp
@@ -161,7 +161,7 @@ void AgentServer::start_workers(ExecEnv* exec_env) {
     _report_tablet_workers = std::make_unique<ReportWorker>(
             "REPORT_OLAP_TABLE", _master_info, config::report_tablet_interval_seconds,[&engine, &master_info = _master_info] { report_tablet_callback(engine, master_info); });
 
-    _clean_trash_binlog_workers = std::make_unique<TaskWorkerPool>(
+    _clean_trash_workers = std::make_unique<TaskWorkerPool>(
             "CLEAN_TRASH", 1, [&engine](auto&& task) {return clean_trash_callback(engine, task); });
     // clang-format on
 }
@@ -270,6 +270,14 @@ void AgentServer::submit_tasks(TAgentResult& agent_result,
                         "task(signature={}) has wrong request member = gc_binlog_req", signature);
             }
             break;
+        case TTaskType::CLEAN_TRASH:
+            if (task.__isset.clean_trash_req) {
+                _clean_trash_workers->submit_task(task);
+            } else {
+                ret_st = Status::InvalidArgument(
+                        "task(signature={}) has wrong request member = clean_trash_req", signature);
+            }
+            break;
         default:
             ret_st = Status::InvalidArgument("task(signature={}, type={}) has wrong task type",
                                              signature, task_type);
diff --git a/be/src/agent/agent_server.h b/be/src/agent/agent_server.h
index 283d2118ce3d8f..b789bbe98de52d 100644
--- a/be/src/agent/agent_server.h
+++ b/be/src/agent/agent_server.h
@@ -96,7 +96,7 @@ class AgentServer {
     std::unique_ptr<TaskWorkerPool> _push_storage_policy_workers;
     std::unique_ptr<TopicSubscriber> _topic_subscriber;
     std::unique_ptr<TaskWorkerPool> _gc_binlog_workers;
-    std::unique_ptr<TaskWorkerPool> _clean_trash_binlog_workers;
+    std::unique_ptr<TaskWorkerPool> _clean_trash_workers;
 };
 
 } // end namespace doris