diff --git a/pkg/archive/clusterConfig.go b/pkg/archive/clusterConfig.go index cb0b502..d14a5ae 100644 --- a/pkg/archive/clusterConfig.go +++ b/pkg/archive/clusterConfig.go @@ -136,7 +136,7 @@ func AssignSubCluster(job *schema.BaseJob) error { } } - if cluster.SubClusters[0].Nodes == "" { + if cluster.SubClusters[0].Nodes == "*" { job.SubCluster = cluster.SubClusters[0].Name return nil }