Skip to content

Commit 2a2a5ac

Browse files
committed
Consistently override the advertised ports
1 parent 4a5df3b commit 2a2a5ac

5 files changed

+187
-532
lines changed

hbase/stackable/bin/hbase-entrypoint.sh

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,10 @@ fi
7878
# Service endpoints
7979
HBASE_SERVICE_HOST=$(cat /stackable/listener/default-address/address)
8080
HBASE_SERVICE_PORT=$(cat /stackable/listener/default-address/ports/"${HBASE_PORT_NAME}")
81+
HBASE_INFO_PORT=$(cat /stackable/listener/default-address/ports/ui-http)
82+
export HBASE_SERVICE_HOST
83+
export HBASE_SERVICE_PORT
84+
export HBASE_INFO_PORT
8185
sed -i -e s/\$\{HBASE_SERVICE_HOST\}/"${HBASE_SERVICE_HOST}"/g /stackable/conf/hbase-site.xml
8286
sed -i -e s/\$\{HBASE_SERVICE_PORT\}/"${HBASE_SERVICE_PORT}"/g /stackable/conf/hbase-site.xml
8387

hbase/stackable/patches/2.6.1/0001-HBASE-28242-Updates-async-profiler-support.patch

Lines changed: 12 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ Date: Tue, 6 Feb 2024 16:10:54 +0100
44
Subject: HBASE-28242: Updates async-profiler support
55

66
---
7-
.../hadoop/hbase/http/ProfileServlet.java | 207 +++++++++++-------
8-
1 file changed, 122 insertions(+), 85 deletions(-)
7+
.../hadoop/hbase/http/ProfileServlet.java | 205 +++++++++++-------
8+
1 file changed, 121 insertions(+), 84 deletions(-)
99

1010
diff --git a/hbase-http/src/main/java/org/apache/hadoop/hbase/http/ProfileServlet.java b/hbase-http/src/main/java/org/apache/hadoop/hbase/http/ProfileServlet.java
1111
index 83087dbed3..6139114717 100644
@@ -106,22 +106,21 @@ index 83087dbed3..6139114717 100644
106106
ALLOC("alloc"),
107107
LOCK("lock"),
108108
- PAGE_FAULTS("page-faults"),
109-
- CONTEXT_SWITCHES("context-switches"),
110-
- CYCLES("cycles"),
111-
- INSTRUCTIONS("instructions"),
112-
- CACHE_REFERENCES("cache-references"),
113-
- CACHE_MISSES("cache-misses"),
114-
- BRANCHES("branches"),
115109
+ ITIMER("itimer"),
116110
+ BRANCH_INSTRUCTIONS("branch-instructions"),
117-
BRANCH_MISSES("branch-misses"),
118-
BUS_CYCLES("bus-cycles"),
111+
+ BRANCH_MISSES("branch-misses"),
112+
+ BUS_CYCLES("bus-cycles"),
119113
+ CACHE_MISSES("cache-misses"),
120114
+ CACHE_REFERENCES("cache-references"),
121-
+ CONTEXT_SWITCHES("context-switches"),
122-
+ CYCLES("cycles"),
115+
CONTEXT_SWITCHES("context-switches"),
116+
CYCLES("cycles"),
123117
+ DTLB_LOAD_MISSES("dTLB-load-misses"),
124-
+ INSTRUCTIONS("instructions"),
118+
INSTRUCTIONS("instructions"),
119+
- CACHE_REFERENCES("cache-references"),
120+
- CACHE_MISSES("cache-misses"),
121+
- BRANCHES("branches"),
122+
- BRANCH_MISSES("branch-misses"),
123+
- BUS_CYCLES("bus-cycles"),
125124
L1_DCACHE_LOAD_MISSES("L1-dcache-load-misses"),
126125
LLC_LOAD_MISSES("LLC-load-misses"),
127126
- DTLB_LOAD_MISSES("dTLB-load-misses"),
Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
From 93620b3eecc29ca0a973891902a3a66944aa2305 Mon Sep 17 00:00:00 2001
2+
From: =?UTF-8?q?Natalie=20Klestrup=20R=C3=B6ijezon?= <[email protected]>
3+
Date: Fri, 30 May 2025 14:26:26 +0200
4+
Subject: Allow overriding ipc bind port
5+
6+
---
7+
.../org/apache/hadoop/hbase/regionserver/RSRpcServices.java | 4 ++--
8+
1 file changed, 2 insertions(+), 2 deletions(-)
9+
10+
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
11+
index b77fcf338a..1f5c9dd21f 100644
12+
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
13+
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
14+
@@ -1270,14 +1270,14 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin
15+
int port = conf.getInt(HConstants.MASTER_PORT, HConstants.DEFAULT_MASTER_PORT);
16+
// Creation of a HSA will force a resolve.
17+
initialIsa = new InetSocketAddress(hostname, port);
18+
- bindAddress = new InetSocketAddress(conf.get("hbase.master.ipc.address", hostname), port);
19+
+ bindAddress = new InetSocketAddress(conf.get("hbase.master.ipc.address", hostname), conf.getInt("hbase.master.ipc.port", port));
20+
} else {
21+
String hostname = DNS.getHostname(conf, DNS.ServerType.REGIONSERVER);
22+
int port = conf.getInt(HConstants.REGIONSERVER_PORT, HConstants.DEFAULT_REGIONSERVER_PORT);
23+
// Creation of a HSA will force a resolve.
24+
initialIsa = new InetSocketAddress(hostname, port);
25+
bindAddress =
26+
- new InetSocketAddress(conf.get("hbase.regionserver.ipc.address", hostname), port);
27+
+ new InetSocketAddress(conf.get("hbase.regionserver.ipc.address", hostname), conf.getInt("hbase.regionserver.ipc.port", port));
28+
}
29+
if (initialIsa.getAddress() == null) {
30+
throw new IllegalArgumentException("Failed resolve of " + initialIsa);

0 commit comments

Comments
 (0)