From c72525a58f019bfa431c548a5210b8f3c558874b Mon Sep 17 00:00:00 2001 From: Jamie Grier Date: Tue, 18 Feb 2020 11:36:57 -0800 Subject: [PATCH] Modify cluster-id to include created_at time. --- pkg/controller/flink/container_utils.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) }