Skip to content

Commit eb06291

Browse files
committed
remove hard-coded names
1 parent a4e3313 commit eb06291

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -580,7 +580,7 @@ pub async fn reconcile_nifi(
580580

581581
let role_group_listener = build_group_listener(
582582
nifi,
583-
build_recommended_labels(nifi, NIFI_CONTROLLER_NAME, "node", "none"),
583+
build_recommended_labels(nifi, NIFI_CONTROLLER_NAME, &nifi_role.to_string(), "none"),
584584
listener_class.to_owned(),
585585
group_listener_name(nifi),
586586
)
@@ -933,9 +933,8 @@ async fn build_node_rolegroup_statefulset(
933933
env_vars.extend(authorization_config.get_env_vars());
934934

935935
let node_address = format!(
936-
"$POD_NAME.{}-node-{}-metrics.{}.svc.{}",
937-
rolegroup_ref.cluster.name,
938-
rolegroup_ref.role_group,
936+
"$POD_NAME.{}.{}.svc.{}",
937+
rolegroup_service_name(rolegroup_ref),
939938
&nifi
940939
.metadata
941940
.namespace

0 commit comments

Comments
 (0)