@@ -442,7 +442,6 @@ pub async fn reconcile_hbase(
442
442
) ?;
443
443
let rg_statefulset = build_rolegroup_statefulset (
444
444
hbase,
445
- & client. kubernetes_cluster_info ,
446
445
& hbase_role,
447
446
& rolegroup,
448
447
rolegroup_config,
@@ -789,7 +788,6 @@ fn build_rolegroup_service(
789
788
#[ allow( clippy:: too_many_arguments) ]
790
789
fn build_rolegroup_statefulset (
791
790
hbase : & v1alpha1:: HbaseCluster ,
792
- cluster_info : & KubernetesClusterInfo ,
793
791
hbase_role : & HbaseRole ,
794
792
rolegroup_ref : & RoleGroupRef < v1alpha1:: HbaseCluster > ,
795
793
rolegroup_config : & HashMap < PropertyNameKind , BTreeMap < String , String > > ,
@@ -897,10 +895,9 @@ fn build_rolegroup_statefulset(
897
895
. image_from_product_image ( resolved_product_image)
898
896
. command ( command ( ) )
899
897
. args ( vec ! [ formatdoc! { "
900
- {entrypoint} {role} {domain} { port} {port_name} {ui_port_name}" ,
898
+ {entrypoint} {role} {port} {port_name} {ui_port_name}" ,
901
899
entrypoint = "/stackable/hbase/bin/hbase-entrypoint.sh" . to_string( ) ,
902
900
role = role_name,
903
- domain = hbase_service_domain_name( hbase, rolegroup_ref, cluster_info) ?,
904
901
port = hbase. service_port( hbase_role) . to_string( ) ,
905
902
port_name = match hbase_role {
906
903
HbaseRole :: Master => "master" ,
@@ -1222,28 +1219,6 @@ fn validate_cr(hbase: &v1alpha1::HbaseCluster) -> Result<()> {
1222
1219
Ok ( ( ) )
1223
1220
}
1224
1221
1225
- /// Build the domain name of an HBase service pod.
1226
- /// The hbase-entrypoint.sh script uses this to build the fully qualified name of a pod
1227
- /// by appending it to the `HOSTNAME` environment variable.
1228
- /// This name is required by the RegionMover to function properly.
1229
- fn hbase_service_domain_name (
1230
- hbase : & v1alpha1:: HbaseCluster ,
1231
- rolegroup_ref : & RoleGroupRef < v1alpha1:: HbaseCluster > ,
1232
- cluster_info : & KubernetesClusterInfo ,
1233
- ) -> Result < String , Error > {
1234
- let hbase_cluster_name = rolegroup_ref. object_name ( ) ;
1235
- let pod_namespace = hbase
1236
- . metadata
1237
- . namespace
1238
- . clone ( )
1239
- . context ( ObjectHasNoNamespaceSnafu ) ?;
1240
- let cluster_domain = & cluster_info. cluster_domain ;
1241
-
1242
- Ok ( format ! (
1243
- "{hbase_cluster_name}.{pod_namespace}.svc.{cluster_domain}"
1244
- ) )
1245
- }
1246
-
1247
1222
#[ cfg( test) ]
1248
1223
mod test {
1249
1224
use rstest:: rstest;
0 commit comments