func GetDefaultEnvironmentVariables()

in pkg/flink/types.go [68:73]


func GetDefaultEnvironmentVariables(taskCtx pluginsCore.TaskExecutionMetadata) EnvVars {
	return utils.UnionMaps(
		config.GetK8sPluginConfig().DefaultEnvVars,
		utils.CopyMap(taskCtx.GetEnvironmentVariables()),
	)
}