diff --git a/services/ai_task_service/cluster/c2net.go b/services/ai_task_service/cluster/c2net.go index c4670fa557..3ac0679a1d 100644 --- a/services/ai_task_service/cluster/c2net.go +++ b/services/ai_task_service/cluster/c2net.go @@ -738,9 +738,7 @@ func (c C2NetClusterAdapter) GetLog(opts entity.ClusterLogOpts) (*entity.Cluster } func getOnlineInferenceLog(opts entity.ClusterLogOpts) string { - helper := storage_helper.SelectUploaderFromStorageType(entity.MINIO) - //查找日志文件 files := getLogFilesInStorage(helper, helper.GetJobDefaultObjectKeyPrefix(opts.JobName)+"/model", ".txt") if len(files) == 0 { @@ -750,16 +748,11 @@ func getOnlineInferenceLog(opts entity.ClusterLogOpts) string { } //默认选择第一个文件 file := files[0] - if opts.Direction == "" { - opts.Direction = entity.UP - } + opts.Direction = entity.UP //计算开始行和结束行 - startLine, endLine := findStartAndEnd(opts, file.RelativePath, helper) - if opts.Lines == -1 { - startLine = 1 - } + _, endLine := findStartAndEnd(opts, file.RelativePath, helper) //获取日志内容 - result, _, _ := getLogInStorage(startLine, endLine, helper, file.RelativePath) + result, _, _ := getLogInStorage(1, endLine, helper, file.RelativePath) return result } @@ -783,7 +776,6 @@ func (c C2NetClusterAdapter) GetLogDownloadInfo(opts entity.ClusterLogDownloadIn JobId: opts.JobId, NodeId: opts.NodeId, WorkServerNum: opts.WorkServerNum, - Lines: -1, }) if err != nil { log.Error("error occurs when attempting to get log content.opts=%+v err=%v", opts, err)