Skip to content

Commit 68ab9cc

Browse files
committed
added listener-relevant config settings
1 parent 8acadff commit 68ab9cc

File tree

1 file changed

+26
-1
lines changed

1 file changed

+26
-1
lines changed

rust/operator-binary/src/hbase_controller.rs

Lines changed: 26 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -597,6 +597,30 @@ fn build_rolegroup_config_map(
597597
hbase_site_config
598598
.extend(hbase_opa_config.map_or(vec![], |config| config.hbase_site_config()));
599599

600+
match hbase_role {
601+
HbaseRole::Master => {
602+
hbase_site_config.insert(
603+
"hbase.listener.master.hostname".to_string(),
604+
"${HBASE_SERVICE_HOST}".to_string(),
605+
);
606+
hbase_site_config.insert(
607+
"hbase.listener.master.port".to_string(),
608+
"${HBASE_SERVICE_PORT}".to_string(),
609+
)
610+
}
611+
HbaseRole::RegionServer => {
612+
hbase_site_config.insert(
613+
"hbase.listener.regionserver.hostname".to_string(),
614+
"${HBASE_SERVICE_HOST}".to_string(),
615+
);
616+
hbase_site_config.insert(
617+
"hbase.listener.regionserver.port".to_string(),
618+
"${HBASE_SERVICE_PORT}".to_string(),
619+
)
620+
}
621+
HbaseRole::RestServer => None,
622+
};
623+
600624
// configOverride come last
601625
hbase_site_config.extend(config.clone());
602626
hbase_site_xml = to_hadoop_xml(
@@ -881,11 +905,12 @@ fn build_rolegroup_statefulset(
881905
.image_from_product_image(resolved_product_image)
882906
.command(command())
883907
.args(vec![formatdoc! {"
884-
{entrypoint} {role} {domain} {port}",
908+
{entrypoint} {role} {domain} {port} {port_name}",
885909
entrypoint = "/stackable/hbase/bin/hbase-entrypoint.sh".to_string(),
886910
role = role_name,
887911
domain = hbase_service_domain_name(hbase, rolegroup_ref, cluster_info)?,
888912
port = hbase.service_port(hbase_role).to_string(),
913+
port_name = hbase.ui_port_name(),
889914
}])
890915
.add_env_vars(merged_env)
891916
// Needed for the `containerdebug` process to log it's tracing information to.

0 commit comments

Comments
 (0)