@@ -520,15 +520,14 @@ pub async fn reconcile_hive(
520520 let mut discovery_hash = FnvHasher :: with_key ( 0 ) ;
521521
522522 if let Some ( HiveMetastoreRoleConfig { listener_class, .. } ) = role_config {
523- let group_listener : Listener =
523+ let role_listener : Listener =
524524 build_role_listener ( hive, & resolved_product_image, & hive_role, listener_class)
525525 . context ( ListenerConfigurationSnafu ) ?;
526- let listener = cluster_resources
527- . add ( client, group_listener)
528- . await
529- . context ( ApplyGroupListenerSnafu {
526+ let listener = cluster_resources. add ( client, role_listener) . await . context (
527+ ApplyGroupListenerSnafu {
530528 role : hive_role. to_string ( ) ,
531- } ) ?;
529+ } ,
530+ ) ?;
532531
533532 for discovery_cm in discovery:: build_discovery_configmaps (
534533 hive,
@@ -961,7 +960,7 @@ fn build_metastore_rolegroup_statefulset(
961960 . build ( ) ;
962961
963962 let pvc = ListenerOperatorVolumeSourceBuilder :: new (
964- & ListenerReference :: ListenerName ( hive. group_listener_name ( hive_role) ) ,
963+ & ListenerReference :: ListenerName ( hive. role_listener_name ( hive_role) ) ,
965964 & unversioned_recommended_labels,
966965 )
967966 . context ( BuildListenerVolumeSnafu ) ?
0 commit comments