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
}