diff --git a/internal/db/models/node_task_dao.go b/internal/db/models/node_task_dao.go
index d2862f2c..97c98c26 100644
--- a/internal/db/models/node_task_dao.go
+++ b/internal/db/models/node_task_dao.go
@@ -154,7 +154,8 @@ func (this *NodeTaskDAO) ExtractNodeClusterTask(tx *dbs.Tx, clusterId int64, use
 	_, err = this.Query(tx).
 		Attr("role", nodeconfigs.NodeRoleNode).
 		Attr("clusterId", clusterId).
-		Where("nodeId> 0").
+		Attr("serverId", serverId).
+		Gt("nodeId", 0).
 		Attr("type", taskType).
 		Delete()
 	if err != nil {