From 2f7447bfb484b5e788e482ac521f72e343298ea4 Mon Sep 17 00:00:00 2001 From: yanafu Date: Mon, 9 Dec 2024 17:15:32 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E6=96=87=E4=BB=B6=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E5=90=8E=E4=BC=9A=E5=B0=9D=E8=AF=95=E5=85=B6?= =?UTF-8?q?=E4=BB=96worker=E6=88=90=E5=8A=9F=E9=87=8D=E8=AF=95=E4=BC=98?= =?UTF-8?q?=E5=8C=96=20#330?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../booster/bk_dist/controller/pkg/manager/local/mgr.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/booster/bk_dist/controller/pkg/manager/local/mgr.go b/src/backend/booster/bk_dist/controller/pkg/manager/local/mgr.go index 324aa00e..0b6a2f1a 100644 --- a/src/backend/booster/bk_dist/controller/pkg/manager/local/mgr.go +++ b/src/backend/booster/bk_dist/controller/pkg/manager/local/mgr.go @@ -258,10 +258,10 @@ func (m *Mgr) ExecuteTask( // 远程任务失败后，将文件大小和压缩大小都置为初始值，方便其他worker重试 for i, c := range remoteReq.Req.Commands { for j, f := range c.Inputfiles { - if f.CompressedSize < 0 && f.InitCompressedSize > 0 { + if f.CompressedSize < 0 && f.InitCompressedSize >= 0 { remoteReq.Req.Commands[i].Inputfiles[j].CompressedSize = remoteReq.Req.Commands[i].Inputfiles[j].InitCompressedSize } - if f.FileSize < 0 && f.InitFileSize > 0 { + if f.FileSize < 0 && f.InitFileSize >= 0 { remoteReq.Req.Commands[i].Inputfiles[j].FileSize = remoteReq.Req.Commands[i].Inputfiles[j].InitFileSize } }