Skip to content

Commit 496444d

Browse files
committed
corrected constant descriptions
1 parent de0c6c7 commit 496444d

File tree

1 file changed

+38
-24
lines changed

1 file changed

+38
-24
lines changed

hbase/hbase/stackable/patches/2.6.1/0005-Allow-overriding-ipc-bind-port-and-use-alternative-p.patch

Lines changed: 38 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -1,60 +1,74 @@
1-
From af804478fc88fdd354611ef2e0374c83874fa685 Mon Sep 17 00:00:00 2001
1+
From e84ed39191101b7dac7a6970afafc00dcec0f135 Mon Sep 17 00:00:00 2001
22
From: =?UTF-8?q?Natalie=20Klestrup=20R=C3=B6ijezon?= <[email protected]>
33
Date: Fri, 30 May 2025 14:26:26 +0200
44
Subject: Allow overriding ipc bind port and use alternative port from listener
55

66
---
7-
.../org/apache/hadoop/hbase/HConstants.java | 21 ++++++++++
7+
.../org/apache/hadoop/hbase/HConstants.java | 29 +++++++++++--
88
.../apache/hadoop/hbase/master/HMaster.java | 20 +++++++--
99
.../hbase/regionserver/HRegionServer.java | 41 +++++++++++++++----
1010
.../hbase/regionserver/RSRpcServices.java | 8 +++-
11-
4 files changed, 76 insertions(+), 14 deletions(-)
11+
4 files changed, 80 insertions(+), 18 deletions(-)
1212

1313
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
14-
index 3b2a58827f..1ba1feefcb 100644
14+
index 3b2a58827f..ea96ff8fce 100644
1515
--- a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
1616
+++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
17-
@@ -197,6 +197,12 @@ public final class HConstants {
18-
/** Parameter name for port master listens on. */
17+
@@ -194,18 +194,27 @@ public final class HConstants {
18+
/** default host address */
19+
public static final String DEFAULT_HOST = "0.0.0.0";
20+
21+
- /** Parameter name for port master listens on. */
22+
+ /** Parameter name for port master advertises as listening on. */
1923
public static final String MASTER_PORT = "hbase.master.port";
2024

21-
+ /** Parameter name for master IPC address */
25+
+ /** Parameter name for IPC address that master listens on. (Defaults to hostname.) */
2226
+ public static final String MASTER_IPC_ADDRESS = "hbase.master.ipc.address";
2327
+
24-
+ /** Parameter name for master IPC port */
28+
+ /** Parameter name for IPC port that master listens on. (Defaults to MASTER_PORT.) */
2529
+ public static final String MASTER_IPC_PORT = "hbase.master.ipc.port";
2630
+
2731
/** default port that the master listens on */
2832
public static final int DEFAULT_MASTER_PORT = 16000;
2933

30-
@@ -206,6 +212,9 @@ public final class HConstants {
31-
/** Configuration key for master web API port */
34+
/** default port for master web api */
35+
public static final int DEFAULT_MASTER_INFOPORT = 16010;
36+
37+
- /** Configuration key for master web API port */
38+
+ /** Configuration key for advertised master web API port */
3239
public static final String MASTER_INFO_PORT = "hbase.master.info.port";
3340

34-
+ /** Configuration key for bound master web API port */
41+
+ /** Configuration key for bound master web API port. (Defaults to MASTER_INFO_PORT.) */
3542
+ public static final String MASTER_BOUND_INFO_PORT = "hbase.master.bound.info.port";
3643
+
3744
/** Configuration key for the list of master host:ports **/
3845
public static final String MASTER_ADDRS_KEY = "hbase.masters";
3946

40-
@@ -316,6 +325,12 @@ public final class HConstants {
41-
/** Parameter name for port region server listens on. */
47+
@@ -313,18 +322,27 @@ public final class HConstants {
48+
/** Default value for ZooKeeper session timeout */
49+
public static final int DEFAULT_ZK_SESSION_TIMEOUT = 90 * 1000;
50+
51+
- /** Parameter name for port region server listens on. */
52+
+ /** Parameter name for port region server advertises as listening on. */
4253
public static final String REGIONSERVER_PORT = "hbase.regionserver.port";
4354

44-
+ /** Parameter name for master IPC address */
55+
+ /** Parameter name for IPC address that region server listens on. (Defaults to hostname.) */
4556
+ public static final String REGIONSERVER_IPC_ADDRESS = "hbase.regionserver.ipc.address";
4657
+
47-
+ /** Parameter name for master IPC port */
58+
+ /** Parameter name for IPC port that region server listens on. (Defaults to REGIONSERVER_PORT.) */
4859
+ public static final String REGIONSERVER_IPC_PORT = "hbase.regionserver.ipc.port";
4960
+
5061
/** Default port region server listens on. */
5162
public static final int DEFAULT_REGIONSERVER_PORT = 16020;
5263

53-
@@ -325,6 +340,9 @@ public final class HConstants {
54-
/** A configuration key for regionserver info port */
64+
/** default port for region server web api */
65+
public static final int DEFAULT_REGIONSERVER_INFOPORT = 16030;
66+
67+
- /** A configuration key for regionserver info port */
68+
+ /** Configuration key for advertised region server web API port */
5569
public static final String REGIONSERVER_INFO_PORT = "hbase.regionserver.info.port";
5670

57-
+ /** A configuration key for bound regionserver hbase info port */
71+
+ /** Configuration key for bound region server web API port. (Defaults to REGIONSERVER_INFO_PORT.) */
5872
+ public static final String REGIONSERVER_BOUND_INFO_PORT = "hbase.regionserver.bound.info.port";
5973
+
6074
/** A flag that enables automatic selection of regionserver info port */
@@ -64,8 +78,8 @@ index 3b2a58827f..1ba1feefcb 100644
6478
/** Configuration key for setting RPC codec class name */
6579
public static final String RPC_CODEC_CONF_KEY = "hbase.client.rpc.codec";
6680

67-
+ /** Configuration key for setting that the RPC client should specify the host */
68-
+ public static final String RPC_CLIENT_SPECIFY_HOST = "hbase.rpc.client.specify.host";
81+
+ /** Configuration key for setting that the RPC client should bind the client address. This forces outgoing RPC traffic to happen from the same network interface that the RPC server is bound on. */
82+
+ public static final String RPC_CLIENT_BIND_ADDRESS = "hbase.client.rpc.bind.address";
6983
+
7084
/** Configuration key for setting replication codec class name */
7185
public static final String REPLICATION_CODEC_CONF_KEY = "hbase.replication.rpc.codec";
@@ -123,7 +137,7 @@ index 3fe5abac27..2f323518da 100644
123137
break;
124138
}
125139
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
126-
index 27bcef2f06..3c180f6cd6 100644
140+
index 27bcef2f06..11bd1e58b5 100644
127141
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
128142
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
129143
@@ -24,6 +24,9 @@ import static org.apache.hadoop.hbase.HConstants.DEFAULT_HBASE_SPLIT_WAL_MAX_SPL
@@ -132,7 +146,7 @@ index 27bcef2f06..3c180f6cd6 100644
132146
import static org.apache.hadoop.hbase.HConstants.HBASE_SPLIT_WAL_MAX_SPLITTER;
133147
+import static org.apache.hadoop.hbase.HConstants.REGIONSERVER_BOUND_INFO_PORT;
134148
+import static org.apache.hadoop.hbase.HConstants.REGIONSERVER_PORT;
135-
+import static org.apache.hadoop.hbase.HConstants.RPC_CLIENT_SPECIFY_HOST;
149+
+import static org.apache.hadoop.hbase.HConstants.RPC_CLIENT_BIND_ADDRESS;
136150
import static org.apache.hadoop.hbase.master.waleventtracker.WALEventTrackerTableCreator.WAL_EVENT_TRACKER_ENABLED_DEFAULT;
137151
import static org.apache.hadoop.hbase.master.waleventtracker.WALEventTrackerTableCreator.WAL_EVENT_TRACKER_ENABLED_KEY;
138152
import static org.apache.hadoop.hbase.namequeues.NamedQueueServiceChore.NAMED_QUEUE_CHORE_DURATION_DEFAULT;
@@ -152,7 +166,7 @@ index 27bcef2f06..3c180f6cd6 100644
152166
rpcServices = createRpcServices();
153167
useThisHostnameInstead = getUseThisHostnameInstead(conf);
154168
+ useThisPortInstead = getUseThisPortInstead(conf);
155-
+ useThisInfoPortInstead = getUseThisInfoPortInstead(conf); //conf.getInt("hbase.info.port" , this.infoServer != null ? this.infoServer.getPort() : -1);
169+
+ useThisInfoPortInstead = getUseThisInfoPortInstead(conf);
156170

157171
// if use-ip is enabled, we will use ip to expose Master/RS service for client,
158172
// see HBASE-27304 for details.
@@ -206,7 +220,7 @@ index 27bcef2f06..3c180f6cd6 100644
206220
}
207221

208222
+ private InetSocketAddress getInetSocketAddress(Configuration conf) {
209-
+ return conf.getBoolean(RPC_CLIENT_SPECIFY_HOST, true) ?
223+
+ return conf.getBoolean(RPC_CLIENT_BIND_ADDRESS, true) ?
210224
+ new InetSocketAddress(this.rpcServices.isa.getAddress(), 0) : new InetSocketAddress(0);
211225
+ }
212226
+

0 commit comments

Comments
 (0)