func GetJobArtifacts()

in pkg/flink/resources.go [217:229]


func GetJobArtifacts(job *flinkIdl.FlinkJob) []string {
	artifacts := job.GetJarFiles()
	if len(artifacts) == 0 {
		// use jflyte artifacts as fallback only
		urls := make([]string, len(job.GetJflyte().GetArtifacts()))
		for i, a := range job.GetJflyte().GetArtifacts() {
			urls[i] = a.Location
		}
		artifacts = urls
	}

	return artifacts
}