in pkg/flink/utils.go [23:34]
func literalMapToFlinkJobArgs(literals map[string]*core.Literal) ([]string, error) {
args := []string{}
for key, literal := range literals {
ls, err := literalToFlinkJobArg(key, literal)
if err != nil {
return nil, err
}
args = append(args, ls...)
}
return args, nil
}