feat: worker选取及恢复机制优化 #311

TencentBlueKing · Nov 28, 2024 · f39e177 · f39e177
1 parent 18dd8b7
commit f39e177
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go b/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go
@@ -1112,10 +1112,11 @@ func (m *Mgr) ensureFiles(
 		blog.Debugf("remote: ensure file %s and match rule %d", fd.File.FilePath, t)
 		servers := make([]*dcProtocol.Host, 0, 0)
 		switch t {
-		case dcSDK.FilterRuleHandleDefault:
-			r = append(r, "")
-			continue
-
+		//此处会导致文件不被发送，注释掉保证文件都在此处发送，共用内存锁避免OOM
+		/*case dcSDK.FilterRuleHandleDefault:
+		r = append(r, "")
+		continue
+		*/
 		case dcSDK.FilterRuleHandleAllDistribution:
 			// cleaner = append(cleaner, f)
 			if err = m.fileMessageBank.ensure(sender, sandbox); err != nil {