@@ -556,14 +556,19 @@ fn build_rolegroup_config_map(
556
556
"org.apache.hadoop.hbase.ipc.BlockingRpcClient" . to_string ( ) ,
557
557
) ;
558
558
559
- // Set listener endpoint information with generic properties
559
+ // Set listener endpoint information
560
560
hbase_site_config. insert (
561
561
"hbase.listener.endpoint" . to_string ( ) ,
562
562
"${HBASE_LISTENER_ENDPOINT}" . to_string ( ) ,
563
563
) ;
564
+
565
+ // Set flag to override default behaviour, which is that the
566
+ // RPC client should bind the client address (forcing outgoing
567
+ // RPC traffic to happen from the same network interface that
568
+ // the RPC server is bound on).
564
569
hbase_site_config. insert (
565
- "hbase.info.port " . to_string ( ) ,
566
- "${HBASE_INFO_PORT} " . to_string ( ) ,
570
+ "hbase.client.rpc.bind.address " . to_string ( ) ,
571
+ "false " . to_string ( ) ,
567
572
) ;
568
573
569
574
match hbase_role {
@@ -584,6 +589,10 @@ fn build_rolegroup_config_map(
584
589
"hbase.master.port" . to_string ( ) ,
585
590
"${HBASE_SERVICE_PORT}" . to_string ( ) ,
586
591
) ;
592
+ hbase_site_config. insert (
593
+ "hbase.master.bound.info.port" . to_string ( ) ,
594
+ "${HBASE_INFO_PORT}" . to_string ( ) ,
595
+ ) ;
587
596
}
588
597
HbaseRole :: RegionServer => {
589
598
hbase_site_config. insert (
@@ -602,6 +611,10 @@ fn build_rolegroup_config_map(
602
611
"hbase.regionserver.port" . to_string ( ) ,
603
612
"${HBASE_SERVICE_PORT}" . to_string ( ) ,
604
613
) ;
614
+ hbase_site_config. insert (
615
+ "hbase.regionserver.bound.info.port" . to_string ( ) ,
616
+ "${HBASE_INFO_PORT}" . to_string ( ) ,
617
+ ) ;
605
618
}
606
619
HbaseRole :: RestServer => { }
607
620
} ;
0 commit comments