diff --git a/pkg/controller/flink/container_utils.go b/pkg/controller/flink/container_utils.go index 38b53bcd..82961449 100644 --- a/pkg/controller/flink/container_utils.go +++ b/pkg/controller/flink/container_utils.go @@ -198,7 +198,7 @@ func InjectOperatorCustomizedConfig(deployment *appsv1.Deployment, app *v1beta1. for _, env := range container.Env { if env.Name == OperatorFlinkConfig { if isHAEnabled(app.Spec.FlinkConfig) { - env.Value = fmt.Sprintf("%s\nhigh-availability.cluster-id: %s-%s\n", env.Value, app.Name, hash) + env.Value = fmt.Sprintf("%s\nhigh-availability.cluster-id: %s-%s-%s\n", env.Value, app.Name, hash, getCreatedAtTime() if deploymentType == FlinkDeploymentTypeJobmanager { env.Value = fmt.Sprintf("%sjobmanager.rpc.address: $HOST_IP\n", env.Value) }