in pkg/flink/handler.go [168:191]
func FlinkClusterTaskLogs(ctx context.Context, config *Config, fi FlinkTaskLogsInput) ([]*core.TaskLog, error) {
var taskLogs []*core.TaskLog
p, err := logs.InitializeLogPlugins(&config.LogConfig)
if err != nil {
return nil, err
}
if p == nil {
return taskLogs, nil
}
jobLog, err := p.GetTaskLogs(tasklog.Input{
PodName: fi.ClusterName,
Namespace: fi.Namespace,
LogName: "(Job)",
})
if err != nil {
return nil, err
}
taskLogs = append(taskLogs, jobLog.TaskLogs...)
return taskLogs, nil
}