HBASE-701 Showing bytes in log when should be String
git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@670651 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
80fa33698f
commit
3af4f2f2f5
|
@ -64,6 +64,7 @@ Hbase Change Log
|
||||||
HBASE-615 Region balancer oscillates during cluster startup
|
HBASE-615 Region balancer oscillates during cluster startup
|
||||||
HBASE-613 Timestamp-anchored scanning fails to find all records
|
HBASE-613 Timestamp-anchored scanning fails to find all records
|
||||||
HBASE-681 NPE in Memcache
|
HBASE-681 NPE in Memcache
|
||||||
|
HBASE-701 Showing bytes in log when should be String
|
||||||
|
|
||||||
|
|
||||||
IMPROVEMENTS
|
IMPROVEMENTS
|
||||||
|
|
|
@ -172,9 +172,8 @@ abstract class BaseScanner extends Chore implements HConstants {
|
||||||
String serverName = Writables.cellToString(values.get(COL_SERVER));
|
String serverName = Writables.cellToString(values.get(COL_SERVER));
|
||||||
long startCode = Writables.cellToLong(values.get(COL_STARTCODE));
|
long startCode = Writables.cellToLong(values.get(COL_STARTCODE));
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug(Thread.currentThread().getName() + " {" +
|
LOG.debug(Thread.currentThread().getName() + info.toString() +
|
||||||
info.toString() + "}, SERVER => '" + serverName +
|
"}, SERVER => '" + serverName + "', STARTCODE => " + startCode);
|
||||||
"', STARTCODE => " + startCode);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Note Region has been assigned.
|
// Note Region has been assigned.
|
||||||
|
|
|
@ -84,7 +84,7 @@ class ChangeTableState extends TableOperation {
|
||||||
// Update meta table
|
// Update meta table
|
||||||
|
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("updating columns in row: " + i.getRegionName());
|
LOG.debug("updating columns in row: " + i.getRegionNameAsString());
|
||||||
}
|
}
|
||||||
|
|
||||||
BatchUpdate b = new BatchUpdate(i.getRegionName());
|
BatchUpdate b = new BatchUpdate(i.getRegionName());
|
||||||
|
@ -93,7 +93,7 @@ class ChangeTableState extends TableOperation {
|
||||||
b.delete(COL_STARTCODE);
|
b.delete(COL_STARTCODE);
|
||||||
server.batchUpdate(m.getRegionName(), b);
|
server.batchUpdate(m.getRegionName(), b);
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("updated columns in row: " + i.getRegionName());
|
LOG.debug("updated columns in row: " + i.getRegionNameAsString());
|
||||||
}
|
}
|
||||||
|
|
||||||
if (online) {
|
if (online) {
|
||||||
|
@ -126,7 +126,7 @@ class ChangeTableState extends TableOperation {
|
||||||
new TreeMap<byte [], HRegionInfo>(Bytes.BYTES_COMPARATOR);
|
new TreeMap<byte [], HRegionInfo>(Bytes.BYTES_COMPARATOR);
|
||||||
for (HRegionInfo i: e.getValue()) {
|
for (HRegionInfo i: e.getValue()) {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("adding region " + i.getRegionName() + " to kill list");
|
LOG.debug("adding region " + i.getRegionNameAsString() + " to kill list");
|
||||||
}
|
}
|
||||||
// this marks the regions to be closed
|
// this marks the regions to be closed
|
||||||
localKillList.put(i.getRegionName(), i);
|
localKillList.put(i.getRegionName(), i);
|
||||||
|
|
|
@ -54,7 +54,7 @@ abstract class ColumnOperation extends TableOperation {
|
||||||
b.put(COL_REGIONINFO, Writables.getBytes(i));
|
b.put(COL_REGIONINFO, Writables.getBytes(i));
|
||||||
server.batchUpdate(regionName, b);
|
server.batchUpdate(regionName, b);
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("updated columns in row: " + i.getRegionName());
|
LOG.debug("updated columns in row: " + i.getRegionNameAsString());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
|
@ -51,7 +51,7 @@ class ProcessRegionClose extends ProcessRegionStatusChange {
|
||||||
/** {@inheritDoc} */
|
/** {@inheritDoc} */
|
||||||
@Override
|
@Override
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return "ProcessRegionClose of " + this.regionInfo.getRegionName() +
|
return "ProcessRegionClose of " + this.regionInfo.getRegionNameAsString() +
|
||||||
", " + this.offlineRegion;
|
", " + this.offlineRegion;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -60,7 +60,7 @@ class ProcessRegionClose extends ProcessRegionStatusChange {
|
||||||
Boolean result =
|
Boolean result =
|
||||||
new RetryableMetaOperation<Boolean>(this.metaRegion, this.master) {
|
new RetryableMetaOperation<Boolean>(this.metaRegion, this.master) {
|
||||||
public Boolean call() throws IOException {
|
public Boolean call() throws IOException {
|
||||||
LOG.info("region closed: " + regionInfo.getRegionName());
|
LOG.info("region closed: " + regionInfo.getRegionNameAsString());
|
||||||
|
|
||||||
// Mark the Region as unavailable in the appropriate meta table
|
// Mark the Region as unavailable in the appropriate meta table
|
||||||
|
|
||||||
|
|
|
@ -423,7 +423,7 @@ class RegionManager implements HConstants {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
LOG.debug("Going to close region " + currentRegion.getRegionName());
|
LOG.debug("Going to close region " + currentRegion.getRegionNameAsString());
|
||||||
|
|
||||||
// make a message to close the region
|
// make a message to close the region
|
||||||
returnMsgs.add(new HMsg(HMsg.Type.MSG_REGION_CLOSE, currentRegion,
|
returnMsgs.add(new HMsg(HMsg.Type.MSG_REGION_CLOSE, currentRegion,
|
||||||
|
|
|
@ -70,6 +70,7 @@ public class TestRegionServerExit extends HBaseClusterTestCase {
|
||||||
// Now abort the meta region server and wait for it to go down and come back
|
// Now abort the meta region server and wait for it to go down and come back
|
||||||
stopOrAbortMetaRegionServer(true);
|
stopOrAbortMetaRegionServer(true);
|
||||||
// Verify that everything is back up.
|
// Verify that everything is back up.
|
||||||
|
LOG.info("Starting up the verification thread for " + getName());
|
||||||
Thread t = startVerificationThread(tableName, row);
|
Thread t = startVerificationThread(tableName, row);
|
||||||
t.start();
|
t.start();
|
||||||
threadDumpingJoin(t);
|
threadDumpingJoin(t);
|
||||||
|
@ -91,6 +92,7 @@ public class TestRegionServerExit extends HBaseClusterTestCase {
|
||||||
// Now abort the meta region server and wait for it to go down and come back
|
// Now abort the meta region server and wait for it to go down and come back
|
||||||
stopOrAbortMetaRegionServer(false);
|
stopOrAbortMetaRegionServer(false);
|
||||||
// Verify that everything is back up.
|
// Verify that everything is back up.
|
||||||
|
LOG.info("Starting up the verification thread for " + getName());
|
||||||
Thread t = startVerificationThread(tableName, row);
|
Thread t = startVerificationThread(tableName, row);
|
||||||
t.start();
|
t.start();
|
||||||
threadDumpingJoin(t);
|
threadDumpingJoin(t);
|
||||||
|
|
Loading…
Reference in New Issue