Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-7027 Use the correct port of info server of region servers 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1401454 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
eclark 2012-10-23 20:39:21 +00:00
parent 2f06bfd297
commit 65a7c12942
5 changed files with 118 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/RegionServerListTmpl.jamon
View File

@ -106,7 +106,7 @@ Arrays.sort(serverNames);
long startcode = serverName.getStartcode();
</%java>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = sl; &></td>
<td><% new Date(startcode) %></td>
<td><% requestsPerSecond %></td>
<td><% numRegionsOnline %></td>
@ -141,7 +141,7 @@ for (ServerName serverName: serverNames) {
if (sl != null) {
</%java>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = sl; &></td>
<td><% sl.getUsedHeapMB() %>MB</td>
<td><% sl.getMaxHeapMB() %>MB</td>
<td><% sl.getMemstoreSizeInMB() %>MB</td>
@ -177,7 +177,7 @@ ServerLoad sl = master.getServerManager().getLoad(serverName);
if (sl != null) {
</%java>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = sl; &></td>
<td><% sl.getRequestsPerSecond() %></td>
<td><% sl.getReadRequestsCount() %></td>
<td><% sl.getWriteRequestsCount() %></td>
@ -215,7 +215,7 @@ ServerLoad sl = master.getServerManager().getLoad(serverName);
if (sl != null) {
</%java>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = sl; &></td>
<td><% sl.getStores() %></td>
<td><% sl.getStorefiles() %></td>
<td><% sl.getStoreUncompressedSizeMB() %>MB</td>
@ -257,7 +257,7 @@ if (sl.getTotalCompactingKVs() > 0) {
}
</%java>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = sl; &></td>
<td><% sl.getTotalCompactingKVs() %></td>
<td><% sl.getCurrentCompactedKVs() %></td>
<td><% percentDone %></td>
@ -277,14 +277,20 @@ if (sl.getTotalCompactingKVs() > 0) {
<%def serverNameLink>
<%args>
ServerName serverName;
ServerLoad serverLoad;
</%args>
<%java>
// TODO: this is incorrect since this conf might differ from RS to RS
// or be set to 0 to get ephemeral ports
int infoPort = master.getConfiguration().getInt("hbase.regionserver.info.port", 60030);
boolean useDefault = (serverLoad == null);
int defaultPort = master.getConfiguration().getInt("hbase.regionserver.info.port", 60030);
int infoPort = useDefault?defaultPort:serverLoad.getInfoServerPort();
String url = "http://" + serverName.getHostname() + ":" + infoPort + "/";
</%java>
<a href="<% url %>"><% serverName.getHostname() %></a>
<%if (infoPort > 0) %>
<a href="<% url %>"><% serverName.getHostname() %></a>
<%else>
<% serverName.getHostname() %>
</%if>
</%def>
<%def emptyStat>
@ -292,7 +298,7 @@ if (sl.getTotalCompactingKVs() > 0) {
ServerName serverName;
</%args>
<tr>
<td><& serverNameLink; serverName=serverName; &></td>
<td><& serverNameLink; serverName=serverName; serverLoad = null; &></td>
<td></td>
<td></td>
<td></td>

4
hbase-server/src/main/java/org/apache/hadoop/hbase/ServerLoad.java
View File

@ -175,6 +175,10 @@ public class ServerLoad {
return serverLoad.getRegionLoadsCount();
}
public int getInfoServerPort() {
return serverLoad.getInfoServerPort();
}
/**
* Originally, this method factored in the effect of requests going to the
* server as well. However, this does not interact very well with the current

109
hbase-server/src/main/java/org/apache/hadoop/hbase/protobuf/generated/HBaseProtos.java
View File

@ -5714,6 +5714,10 @@ public final class HBaseProtos {
// optional uint64 reportEndTime = 8;
boolean hasReportEndTime();
long getReportEndTime();
// optional uint32 infoServerPort = 9;
boolean hasInfoServerPort();
int getInfoServerPort();
}
public static final class ServerLoad extends
com.google.protobuf.GeneratedMessage
@ -5846,6 +5850,16 @@ public final class HBaseProtos {
return reportEndTime_;
}
// optional uint32 infoServerPort = 9;
public static final int INFOSERVERPORT_FIELD_NUMBER = 9;
private int infoServerPort_;
public boolean hasInfoServerPort() {
return ((bitField0_ & 0x00000040) == 0x00000040);
}
public int getInfoServerPort() {
return infoServerPort_;
}
private void initFields() {
numberOfRequests_ = 0;
totalNumberOfRequests_ = 0;
@ -5855,6 +5869,7 @@ public final class HBaseProtos {
coprocessors_ = java.util.Collections.emptyList();
reportStartTime_ = 0L;
reportEndTime_ = 0L;
infoServerPort_ = 0;
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
@ -5904,6 +5919,9 @@ public final class HBaseProtos {
if (((bitField0_ & 0x00000020) == 0x00000020)) {
output.writeUInt64(8, reportEndTime_);
}
if (((bitField0_ & 0x00000040) == 0x00000040)) {
output.writeUInt32(9, infoServerPort_);
}
getUnknownFields().writeTo(output);
}
@ -5945,6 +5963,10 @@ public final class HBaseProtos {
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(8, reportEndTime_);
}
if (((bitField0_ & 0x00000040) == 0x00000040)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(9, infoServerPort_);
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
@ -6002,6 +6024,11 @@ public final class HBaseProtos {
result = result && (getReportEndTime()
== other.getReportEndTime());
}
result = result && (hasInfoServerPort() == other.hasInfoServerPort());
if (hasInfoServerPort()) {
result = result && (getInfoServerPort()
== other.getInfoServerPort());
}
result = result &&
getUnknownFields().equals(other.getUnknownFields());
return result;
@ -6043,6 +6070,10 @@ public final class HBaseProtos {
hash = (37 * hash) + REPORTENDTIME_FIELD_NUMBER;
hash = (53 * hash) + hashLong(getReportEndTime());
}
if (hasInfoServerPort()) {
hash = (37 * hash) + INFOSERVERPORT_FIELD_NUMBER;
hash = (53 * hash) + getInfoServerPort();
}
hash = (29 * hash) + getUnknownFields().hashCode();
return hash;
}
@ -6185,6 +6216,8 @@ public final class HBaseProtos {
bitField0_ = (bitField0_ & ~0x00000040);
reportEndTime_ = 0L;
bitField0_ = (bitField0_ & ~0x00000080);
infoServerPort_ = 0;
bitField0_ = (bitField0_ & ~0x00000100);
return this;
}
@ -6265,6 +6298,10 @@ public final class HBaseProtos {
to_bitField0_ |= 0x00000020;
}
result.reportEndTime_ = reportEndTime_;
if (((from_bitField0_ & 0x00000100) == 0x00000100)) {
to_bitField0_ |= 0x00000040;
}
result.infoServerPort_ = infoServerPort_;
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@ -6351,6 +6388,9 @@ public final class HBaseProtos {
if (other.hasReportEndTime()) {
setReportEndTime(other.getReportEndTime());
}
if (other.hasInfoServerPort()) {
setInfoServerPort(other.getInfoServerPort());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
@ -6436,6 +6476,11 @@ public final class HBaseProtos {
reportEndTime_ = input.readUInt64();
break;
}
case 72: {
bitField0_ |= 0x00000100;
infoServerPort_ = input.readUInt32();
break;
}
}
}
}
@ -6940,6 +6985,27 @@ public final class HBaseProtos {
return this;
}
// optional uint32 infoServerPort = 9;
private int infoServerPort_ ;
public boolean hasInfoServerPort() {
return ((bitField0_ & 0x00000100) == 0x00000100);
}
public int getInfoServerPort() {
return infoServerPort_;
}
public Builder setInfoServerPort(int value) {
bitField0_ |= 0x00000100;
infoServerPort_ = value;
onChanged();
return this;
}
public Builder clearInfoServerPort() {
bitField0_ = (bitField0_ & ~0x00000100);
infoServerPort_ = 0;
onChanged();
return this;
}
// @@protoc_insertion_point(builder_scope:ServerLoad)
}
@ -11169,30 +11235,31 @@ public final class HBaseProtos {
"otalStaticIndexSizeKB\030\r \001(\r\022\036\n\026totalStat" +
"icBloomSizeKB\030\016 \001(\r\022\"\n\014coprocessors\030\017 \003(" +
"\0132\014.Coprocessor\022\032\n\022completeSequenceId\030\020 " +
"\001(\004\"\342\001\n\nServerLoad\022\030\n\020numberOfRequests\030\001" +
"\001(\004\"\372\001\n\nServerLoad\022\030\n\020numberOfRequests\030\001" +
" \001(\r\022\035\n\025totalNumberOfRequests\030\002 \001(\r\022\022\n\nu" +
"sedHeapMB\030\003 \001(\r\022\021\n\tmaxHeapMB\030\004 \001(\r\022 \n\013re" +
"gionLoads\030\005 \003(\0132\013.RegionLoad\022\"\n\014coproces",
"sors\030\006 \003(\0132\014.Coprocessor\022\027\n\017reportStartT" +
"ime\030\007 \001(\004\022\025\n\rreportEndTime\030\010 \001(\004\"%\n\tTime" +
"Range\022\014\n\004from\030\001 \001(\004\022\n\n\002to\030\002 \001(\004\"0\n\006Filte" +
"r\022\014\n\004name\030\001 \002(\t\022\030\n\020serializedFilter\030\002 \001(" +
"\014\"w\n\010KeyValue\022\013\n\003row\030\001 \002(\014\022\016\n\006family\030\002 \002" +
"(\014\022\021\n\tqualifier\030\003 \002(\014\022\021\n\ttimestamp\030\004 \001(\004" +
"\022\031\n\007keyType\030\005 \001(\0162\010.KeyType\022\r\n\005value\030\006 \001" +
"(\014\"?\n\nServerName\022\020\n\010hostName\030\001 \002(\t\022\014\n\004po" +
"rt\030\002 \001(\r\022\021\n\tstartCode\030\003 \001(\004\"\033\n\013Coprocess" +
"or\022\014\n\004name\030\001 \002(\t\"-\n\016NameStringPair\022\014\n\004na",
"me\030\001 \002(\t\022\r\n\005value\030\002 \002(\t\",\n\rNameBytesPair" +
"\022\014\n\004name\030\001 \002(\t\022\r\n\005value\030\002 \001(\014\"/\n\016BytesBy" +
"tesPair\022\r\n\005first\030\001 \002(\014\022\016\n\006second\030\002 \002(\014*r" +
"\n\013CompareType\022\010\n\004LESS\020\000\022\021\n\rLESS_OR_EQUAL" +
"\020\001\022\t\n\005EQUAL\020\002\022\r\n\tNOT_EQUAL\020\003\022\024\n\020GREATER_" +
"OR_EQUAL\020\004\022\013\n\007GREATER\020\005\022\t\n\005NO_OP\020\006*_\n\007Ke" +
"yType\022\013\n\007MINIMUM\020\000\022\007\n\003PUT\020\004\022\n\n\006DELETE\020\010\022" +
"\021\n\rDELETE_COLUMN\020\014\022\021\n\rDELETE_FAMILY\020\016\022\014\n" +
"\007MAXIMUM\020\377\001B>\n*org.apache.hadoop.hbase.p" +
"rotobuf.generatedB\013HBaseProtosH\001\240\001\001"
"ime\030\007 \001(\004\022\025\n\rreportEndTime\030\010 \001(\004\022\026\n\016info" +
"ServerPort\030\t \001(\r\"%\n\tTimeRange\022\014\n\004from\030\001 " +
"\001(\004\022\n\n\002to\030\002 \001(\004\"0\n\006Filter\022\014\n\004name\030\001 \002(\t\022" +
"\030\n\020serializedFilter\030\002 \001(\014\"w\n\010KeyValue\022\013\n" +
"\003row\030\001 \002(\014\022\016\n\006family\030\002 \002(\014\022\021\n\tqualifier\030" +
"\003 \002(\014\022\021\n\ttimestamp\030\004 \001(\004\022\031\n\007keyType\030\005 \001(" +
"\0162\010.KeyType\022\r\n\005value\030\006 \001(\014\"?\n\nServerName" +
"\022\020\n\010hostName\030\001 \002(\t\022\014\n\004port\030\002 \001(\r\022\021\n\tstar" +
"tCode\030\003 \001(\004\"\033\n\013Coprocessor\022\014\n\004name\030\001 \002(\t",
"\"-\n\016NameStringPair\022\014\n\004name\030\001 \002(\t\022\r\n\005valu" +
"e\030\002 \002(\t\",\n\rNameBytesPair\022\014\n\004name\030\001 \002(\t\022\r" +
"\n\005value\030\002 \001(\014\"/\n\016BytesBytesPair\022\r\n\005first" +
"\030\001 \002(\014\022\016\n\006second\030\002 \002(\014*r\n\013CompareType\022\010\n" +
"\004LESS\020\000\022\021\n\rLESS_OR_EQUAL\020\001\022\t\n\005EQUAL\020\002\022\r\n" +
"\tNOT_EQUAL\020\003\022\024\n\020GREATER_OR_EQUAL\020\004\022\013\n\007GR" +
"EATER\020\005\022\t\n\005NO_OP\020\006*_\n\007KeyType\022\013\n\007MINIMUM" +
"\020\000\022\007\n\003PUT\020\004\022\n\n\006DELETE\020\010\022\021\n\rDELETE_COLUMN" +
"\020\014\022\021\n\rDELETE_FAMILY\020\016\022\014\n\007MAXIMUM\020\377\001B>\n*o" +
"rg.apache.hadoop.hbase.protobuf.generate",
"dB\013HBaseProtosH\001\240\001\001"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@ -11260,7 +11327,7 @@ public final class HBaseProtos {
internal_static_ServerLoad_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_ServerLoad_descriptor,
new java.lang.String[] { "NumberOfRequests", "TotalNumberOfRequests", "UsedHeapMB", "MaxHeapMB", "RegionLoads", "Coprocessors", "ReportStartTime", "ReportEndTime", },
new java.lang.String[] { "NumberOfRequests", "TotalNumberOfRequests", "UsedHeapMB", "MaxHeapMB", "RegionLoads", "Coprocessors", "ReportStartTime", "ReportEndTime", "InfoServerPort", },
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ServerLoad.class,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ServerLoad.Builder.class);
internal_static_TimeRange_descriptor =

6
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
View File

@ -1058,7 +1058,11 @@ public class HRegionServer implements ClientProtocol,
}
serverLoad.setReportStartTime(reportStartTime);
serverLoad.setReportEndTime(reportEndTime);
if (this.infoServer != null) {
serverLoad.setInfoServerPort(this.infoServer.getPort());
} else {
serverLoad.setInfoServerPort(-1);
}
return serverLoad.build();
}

5
hbase-server/src/main/protobuf/hbase.proto
View File

@ -175,6 +175,11 @@ message ServerLoad {
* and midnight, January 1, 1970 UTC.
*/
optional uint64 reportEndTime = 8;
/**
* The port number that this region server is hosing an info server on.
*/
optional uint32 infoServerPort = 9;
}
/**