You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2011/05/25 07:05:40 UTC
svn commit: r1127383 - in /hbase/branches/0.90: ./
src/main/java/org/apache/hadoop/hbase/catalog/
src/main/java/org/apache/hadoop/hbase/client/
src/main/java/org/apache/hadoop/hbase/executor/
src/main/java/org/apache/hadoop/hbase/io/ src/main/java/org/...
Author: stack
Date: Wed May 25 05:05:39 2011
New Revision: 1127383
URL: http://svn.apache.org/viewvc?rev=1127383&view=rev
Log:
HBASE-3919 More places output binary data to text
Modified:
hbase/branches/0.90/CHANGES.txt
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/MetaEditor.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Delete.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Get.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Increment.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/MetaScanner.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Put.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Result.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/executor/RegionTransitionData.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/io/HalfStoreFileReader.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/HMerge.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/Merge.java
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/MetaUtils.java
Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Wed May 25 05:05:39 2011
@@ -26,6 +26,7 @@ Release 0.90.4 - Unreleased
sun jre provided by RHEL6 (Roman Shaposhnik)
HBASE-3920 HLog hbase.regionserver.flushlogentries no longer supported
(Dave Latham)
+ HBASE-3919 More places output binary data to text (Dave Latham)
Release 0.90.3 - May 19th, 2011
BUG FIXES
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java Wed May 25 05:05:39 2011
@@ -442,7 +442,7 @@ public class CatalogTracker {
throw e;
}
}
- LOG.info("Failed verification of " + Bytes.toString(regionName) +
+ LOG.info("Failed verification of " + Bytes.toStringBinary(regionName) +
" at address=" + address + "; " + t);
return false;
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/MetaEditor.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/MetaEditor.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/MetaEditor.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/catalog/MetaEditor.java Wed May 25 05:05:39 2011
@@ -163,7 +163,7 @@ public class MetaEditor {
addLocation(put, serverInfo);
server.put(catalogRegionName, put);
LOG.info("Updated row " + regionInfo.getRegionNameAsString() +
- " in region " + Bytes.toString(catalogRegionName) + " with " +
+ " in region " + Bytes.toStringBinary(catalogRegionName) + " with " +
"server=" + serverInfo.getHostnamePort() + ", " +
"startcode=" + serverInfo.getStartCode());
}
@@ -201,7 +201,7 @@ public class MetaEditor {
catalogTracker.waitForMetaServerConnectionDefault().
delete(CatalogTracker.META_REGION, delete);
LOG.info("Deleted daughter reference " + daughter.getRegionNameAsString() +
- ", qualifier=" + Bytes.toString(qualifier) + ", from parent " +
+ ", qualifier=" + Bytes.toStringBinary(qualifier) + ", from parent " +
parent.getRegionNameAsString());
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Delete.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Delete.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Delete.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Delete.java Wed May 25 05:05:39 2011
@@ -290,7 +290,7 @@ public class Delete implements Writable,
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("row=");
- sb.append(Bytes.toString(this.row));
+ sb.append(Bytes.toStringBinary(this.row));
sb.append(", ts=");
sb.append(this.ts);
sb.append(", families={");
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Get.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Get.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Get.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Get.java Wed May 25 05:05:39 2011
@@ -306,7 +306,7 @@ public class Get implements Writable, Ro
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("row=");
- sb.append(Bytes.toString(this.row));
+ sb.append(Bytes.toStringBinary(this.row));
sb.append(", maxVersions=");
sb.append("").append(this.maxVersions);
sb.append(", cacheBlocks=");
@@ -342,7 +342,7 @@ public class Get implements Writable, Ro
} else {
moreThanOneB = true;
}
- sb.append(Bytes.toString(column));
+ sb.append(Bytes.toStringBinary(column));
}
sb.append("}");
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java Wed May 25 05:05:39 2011
@@ -774,7 +774,7 @@ public class HBaseAdmin implements Abort
MetaReader.getRegion(ct, regionname);
if (pair == null || pair.getSecond() == null) {
LOG.info("No server in .META. for " +
- Bytes.toString(regionname) + "; pair=" + pair);
+ Bytes.toStringBinary(regionname) + "; pair=" + pair);
} else {
closeRegion(pair.getSecond(), pair.getFirst());
}
@@ -822,7 +822,7 @@ public class HBaseAdmin implements Abort
MetaReader.getRegion(ct, tableNameOrRegionName);
if (pair == null || pair.getSecond() == null) {
LOG.info("No server in .META. for " +
- Bytes.toString(tableNameOrRegionName) + "; pair=" + pair);
+ Bytes.toStringBinary(tableNameOrRegionName) + "; pair=" + pair);
} else {
flush(pair.getSecond(), pair.getFirst());
}
@@ -924,7 +924,7 @@ public class HBaseAdmin implements Abort
MetaReader.getRegion(ct, tableNameOrRegionName);
if (pair == null || pair.getSecond() == null) {
LOG.info("No server in .META. for " +
- Bytes.toString(tableNameOrRegionName) + "; pair=" + pair);
+ Bytes.toStringBinary(tableNameOrRegionName) + "; pair=" + pair);
} else {
compact(pair.getSecond(), pair.getFirst(), major);
}
@@ -1074,7 +1074,7 @@ public class HBaseAdmin implements Abort
MetaReader.getRegion(ct, tableNameOrRegionName);
if (pair == null || pair.getSecond() == null) {
LOG.info("No server in .META. for " +
- Bytes.toString(tableNameOrRegionName) + "; pair=" + pair);
+ Bytes.toStringBinary(tableNameOrRegionName) + "; pair=" + pair);
} else {
split(pair.getSecond(), pair.getFirst(), splitPoint);
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Increment.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Increment.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Increment.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Increment.java Wed May 25 05:05:39 2011
@@ -225,7 +225,7 @@ public class Increment implements Writab
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("row=");
- sb.append(Bytes.toString(this.row));
+ sb.append(Bytes.toStringBinary(this.row));
if(this.familyMap.size() == 0) {
sb.append(", no columns set to be incremented");
return sb.toString();
@@ -254,7 +254,7 @@ public class Increment implements Writab
} else {
moreThanOneB = true;
}
- sb.append(Bytes.toString(column.getKey()) + "+=" + column.getValue());
+ sb.append(Bytes.toStringBinary(column.getKey()) + "+=" + column.getValue());
}
sb.append("}");
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/MetaScanner.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/MetaScanner.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/MetaScanner.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/MetaScanner.java Wed May 25 05:05:39 2011
@@ -134,13 +134,13 @@ public class MetaScanner {
HConstants.CATALOG_FAMILY);
if (startRowResult == null) {
throw new TableNotFoundException("Cannot find row in .META. for table: "
- + Bytes.toString(tableName) + ", row=" + Bytes.toString(searchRow));
+ + Bytes.toString(tableName) + ", row=" + Bytes.toStringBinary(searchRow));
}
byte[] value = startRowResult.getValue(HConstants.CATALOG_FAMILY,
HConstants.REGIONINFO_QUALIFIER);
if (value == null || value.length == 0) {
throw new IOException("HRegionInfo was null or empty in Meta for " +
- Bytes.toString(tableName) + ", row=" + Bytes.toString(searchRow));
+ Bytes.toString(tableName) + ", row=" + Bytes.toStringBinary(searchRow));
}
HRegionInfo regionInfo = Writables.getHRegionInfo(value);
@@ -164,7 +164,7 @@ public class MetaScanner {
final Scan scan = new Scan(startRow).addFamily(HConstants.CATALOG_FAMILY);
if (LOG.isDebugEnabled()) {
LOG.debug("Scanning " + Bytes.toString(metaTableName) +
- " starting at row=" + Bytes.toString(startRow) + " for max=" +
+ " starting at row=" + Bytes.toStringBinary(startRow) + " for max=" +
rowUpperLimit + " rows");
}
callable = new ScannerCallable(connection, metaTableName, scan);
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Put.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Put.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Put.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Put.java Wed May 25 05:05:39 2011
@@ -414,7 +414,7 @@ public class Put implements HeapSize, Wr
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("row=");
- sb.append(Bytes.toString(this.row));
+ sb.append(Bytes.toStringBinary(this.row));
sb.append(", families={");
boolean moreThanOne = false;
for(Map.Entry<byte [], List<KeyValue>> entry : this.familyMap.entrySet()) {
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Result.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Result.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Result.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/client/Result.java Wed May 25 05:05:39 2011
@@ -664,7 +664,7 @@ public class Result implements Writable,
throws Exception {
if (res2 == null) {
throw new Exception("There wasn't enough rows, we stopped at "
- + Bytes.toString(res1.getRow()));
+ + Bytes.toStringBinary(res1.getRow()));
}
if (res1.size() != res2.size()) {
throw new Exception("This row doesn't have the same number of KVs: "
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/executor/RegionTransitionData.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/executor/RegionTransitionData.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/executor/RegionTransitionData.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/executor/RegionTransitionData.java Wed May 25 05:05:39 2011
@@ -207,4 +207,4 @@ public class RegionTransitionData implem
return "region=" + Bytes.toStringBinary(regionName) +
", server=" + serverName + ", state=" + eventType;
}
-}
+}
\ No newline at end of file
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/io/HalfStoreFileReader.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/io/HalfStoreFileReader.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/io/HalfStoreFileReader.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/io/HalfStoreFileReader.java Wed May 25 05:05:39 2011
@@ -258,7 +258,7 @@ public class HalfStoreFileReader extends
return Bytes.toBytes(scanner.getKey());
}
} catch (IOException e) {
- LOG.warn("Failed seekBefore " + Bytes.toString(this.splitkey), e);
+ LOG.warn("Failed seekBefore " + Bytes.toStringBinary(this.splitkey), e);
}
return null;
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java Wed May 25 05:05:39 2011
@@ -101,7 +101,7 @@ implements Configurable {
if (this.lastReduces != reduces) {
this.splits = Bytes.split(this.startkey, this.endkey, reduces - 1);
for (int i = 0; i < splits.length; i++) {
- LOG.info(Bytes.toString(splits[i]));
+ LOG.info(Bytes.toStringBinary(splits[i]));
}
}
int pos = Bytes.binarySearch(this.splits, key.get(), key.getOffset(),
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/HMaster.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/HMaster.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/HMaster.java Wed May 25 05:05:39 2011
@@ -722,7 +722,7 @@ implements HMasterInterface, HMasterRegi
Pair<HRegionInfo, HServerInfo> p =
this.assignmentManager.getAssignment(encodedRegionName);
if (p == null)
- throw new UnknownRegionException(Bytes.toString(encodedRegionName));
+ throw new UnknownRegionException(Bytes.toStringBinary(encodedRegionName));
HRegionInfo hri = p.getFirst();
HServerInfo dest = null;
if (destServerName == null || destServerName.length == 0) {
@@ -1039,7 +1039,7 @@ implements HMasterInterface, HMasterRegi
throws IOException {
Pair<HRegionInfo, HServerAddress> pair =
MetaReader.getRegion(this.catalogTracker, regionName);
- if (pair == null) throw new UnknownRegionException(Bytes.toString(regionName));
+ if (pair == null) throw new UnknownRegionException(Bytes.toStringBinary(regionName));
HRegionInfo hri = pair.getFirst();
if (force) this.assignmentManager.clearRegionFromTransition(hri);
this.assignmentManager.unassign(hri, force);
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java Wed May 25 05:05:39 2011
@@ -2766,8 +2766,8 @@ public class HRegion implements HeapSize
LOG.info("starting merge of regions: " + a + " and " + b +
" into new region " + newRegionInfo.toString() +
- " with start key <" + Bytes.toString(startKey) + "> and end key <" +
- Bytes.toString(endKey) + ">");
+ " with start key <" + Bytes.toStringBinary(startKey) + "> and end key <" +
+ Bytes.toStringBinary(endKey) + ">");
// Move HStoreFiles under new region directory
Map<byte [], List<StoreFile>> byFamily =
@@ -3185,7 +3185,7 @@ public class HRegion implements HeapSize
throws NoSuchColumnFamilyException {
if(!regionInfo.getTableDesc().hasFamily(family)) {
throw new NoSuchColumnFamilyException("Column family " +
- Bytes.toString(family) + " does not exist in region " + this
+ Bytes.toStringBinary(family) + " does not exist in region " + this
+ " in table " + regionInfo.getTableDesc());
}
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java Wed May 25 05:05:39 2011
@@ -403,7 +403,7 @@ class MemStoreFlusher extends Thread imp
return false;
} catch (IOException ex) {
LOG.error("Cache flush failed" +
- (region != null ? (" for region " + Bytes.toString(region.getRegionName())) : ""),
+ (region != null ? (" for region " + Bytes.toStringBinary(region.getRegionName())) : ""),
RemoteExceptionHandler.checkIOException(ex));
if (!server.checkFileSystem()) {
return false;
@@ -532,7 +532,7 @@ class MemStoreFlusher extends Thread imp
@Override
public String toString() {
- return "[flush region " + Bytes.toString(region.getRegionName()) + "]";
+ return "[flush region " + Bytes.toStringBinary(region.getRegionName()) + "]";
}
}
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java Wed May 25 05:05:39 2011
@@ -151,7 +151,7 @@ class SplitTransaction {
if (Bytes.equals(startKey, splitrow) ||
!this.parent.getRegionInfo().containsRow(splitrow)) {
LOG.info("Split row is not inside region key range or is equal to " +
- "startkey: " + Bytes.toString(this.splitrow));
+ "startkey: " + Bytes.toStringBinary(this.splitrow));
return false;
}
long rid = getDaughterRegionIdTimestamp(hri);
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java Wed May 25 05:05:39 2011
@@ -626,7 +626,7 @@ public class HLog implements Syncable {
LOG.debug("Found " + logsToRemove + " hlogs to remove" +
" out of total " + this.outputfiles.size() + ";" +
" oldest outstanding sequenceid is " + oldestOutstandingSeqNum +
- " from region " + Bytes.toString(oldestRegion));
+ " from region " + Bytes.toStringBinary(oldestRegion));
}
for (Long seq : sequenceNumbers) {
archiveLogFile(this.outputfiles.remove(seq), seq);
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/HMerge.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/HMerge.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/HMerge.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/HMerge.java Wed May 25 05:05:39 2011
@@ -204,8 +204,8 @@ class HMerge {
mergedRegion);
break;
}
- LOG.info("not merging regions " + Bytes.toString(currentRegion.getRegionName())
- + " and " + Bytes.toString(nextRegion.getRegionName()));
+ LOG.info("not merging regions " + Bytes.toStringBinary(currentRegion.getRegionName())
+ + " and " + Bytes.toStringBinary(nextRegion.getRegionName()));
currentRegion.close();
currentRegion = nextRegion;
currentSize = nextSize;
@@ -277,7 +277,7 @@ class HMerge {
Result currentRow = metaScanner.next();
boolean foundResult = false;
while (currentRow != null) {
- LOG.info("Row: <" + Bytes.toString(currentRow.getRow()) + ">");
+ LOG.info("Row: <" + Bytes.toStringBinary(currentRow.getRow()) + ">");
byte[] regionInfoValue = currentRow.getValue(HConstants.CATALOG_FAMILY,
HConstants.REGIONINFO_QUALIFIER);
if (regionInfoValue == null || regionInfoValue.length == 0) {
@@ -319,7 +319,7 @@ class HMerge {
Delete delete = new Delete(regionsToDelete[r]);
table.delete(delete);
if(LOG.isDebugEnabled()) {
- LOG.debug("updated columns in row: " + Bytes.toString(regionsToDelete[r]));
+ LOG.debug("updated columns in row: " + Bytes.toStringBinary(regionsToDelete[r]));
}
}
newRegion.getRegionInfo().setOffline(true);
@@ -331,7 +331,7 @@ class HMerge {
if(LOG.isDebugEnabled()) {
LOG.debug("updated columns in row: "
- + Bytes.toString(newRegion.getRegionName()));
+ + Bytes.toStringBinary(newRegion.getRegionName()));
}
}
}
@@ -412,7 +412,7 @@ class HMerge {
root.delete(delete, null, true);
if(LOG.isDebugEnabled()) {
- LOG.debug("updated columns in row: " + Bytes.toString(regionsToDelete[r]));
+ LOG.debug("updated columns in row: " + Bytes.toStringBinary(regionsToDelete[r]));
}
}
HRegionInfo newInfo = newRegion.getRegionInfo();
@@ -422,7 +422,7 @@ class HMerge {
Writables.getBytes(newInfo));
root.put(put);
if(LOG.isDebugEnabled()) {
- LOG.debug("updated columns in row: " + Bytes.toString(newRegion.getRegionName()));
+ LOG.debug("updated columns in row: " + Bytes.toStringBinary(newRegion.getRegionName()));
}
}
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/Merge.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/Merge.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/Merge.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/Merge.java Wed May 25 05:05:39 2011
@@ -196,22 +196,22 @@ public class Merge extends Configured im
* Merges two regions from a user table.
*/
private void mergeTwoRegions() throws IOException {
- LOG.info("Merging regions " + Bytes.toString(this.region1) + " and " +
- Bytes.toString(this.region2) + " in table " + Bytes.toString(this.tableName));
+ LOG.info("Merging regions " + Bytes.toStringBinary(this.region1) + " and " +
+ Bytes.toStringBinary(this.region2) + " in table " + Bytes.toString(this.tableName));
// Scan the root region for all the meta regions that contain the regions
// we're merging.
MetaScannerListener listener = new MetaScannerListener(region1, region2);
this.utils.scanRootRegion(listener);
HRegionInfo meta1 = listener.getMeta1();
if (meta1 == null) {
- throw new IOException("Could not find meta region for " + Bytes.toString(region1));
+ throw new IOException("Could not find meta region for " + Bytes.toStringBinary(region1));
}
HRegionInfo meta2 = listener.getMeta2();
if (meta2 == null) {
- throw new IOException("Could not find meta region for " + Bytes.toString(region2));
+ throw new IOException("Could not find meta region for " + Bytes.toStringBinary(region2));
}
- LOG.info("Found meta for region1 " + Bytes.toString(meta1.getRegionName()) +
- ", meta for region2 " + Bytes.toString(meta2.getRegionName()));
+ LOG.info("Found meta for region1 " + Bytes.toStringBinary(meta1.getRegionName()) +
+ ", meta for region2 " + Bytes.toStringBinary(meta2.getRegionName()));
HRegion metaRegion1 = this.utils.getMetaRegion(meta1);
Get get = new Get(region1);
get.addColumn(HConstants.CATALOG_FAMILY, HConstants.REGIONINFO_QUALIFIER);
@@ -219,7 +219,7 @@ public class Merge extends Configured im
HRegionInfo info1 = Writables.getHRegionInfo((cells1 == null)? null: cells1.get(0).getValue());
if (info1== null) {
throw new NullPointerException("info1 is null using key " +
- Bytes.toString(region1) + " in " + meta1);
+ Bytes.toStringBinary(region1) + " in " + meta1);
}
HRegion metaRegion2;
@@ -244,7 +244,7 @@ public class Merge extends Configured im
HRegionInfo mergedInfo = listener.getMeta1();
if (mergedInfo == null) {
throw new IOException("Could not find meta region for " +
- Bytes.toString(merged.getRegionName()));
+ Bytes.toStringBinary(merged.getRegionName()));
}
HRegion mergeMeta;
if (Bytes.equals(mergedInfo.getRegionName(), meta1.getRegionName())) {
@@ -271,12 +271,12 @@ public class Merge extends Configured im
HRegion meta2)
throws IOException {
if (info1 == null) {
- throw new IOException("Could not find " + Bytes.toString(region1) + " in " +
- Bytes.toString(meta1.getRegionName()));
+ throw new IOException("Could not find " + Bytes.toStringBinary(region1) + " in " +
+ Bytes.toStringBinary(meta1.getRegionName()));
}
if (info2 == null) {
- throw new IOException("Cound not find " + Bytes.toString(region2) + " in " +
- Bytes.toString(meta2.getRegionName()));
+ throw new IOException("Cound not find " + Bytes.toStringBinary(region2) + " in " +
+ Bytes.toStringBinary(meta2.getRegionName()));
}
HRegion merged = null;
HLog log = utils.getLog();
@@ -361,7 +361,7 @@ public class Merge extends Configured im
private boolean notInTable(final byte [] tn, final byte [] rn) {
if (WritableComparator.compareBytes(tn, 0, tn.length, rn, 0, tn.length) != 0) {
- LOG.error("Region " + Bytes.toString(rn) + " does not belong to table " +
+ LOG.error("Region " + Bytes.toStringBinary(rn) + " does not belong to table " +
Bytes.toString(tn));
return true;
}
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/MetaUtils.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/MetaUtils.java?rev=1127383&r1=1127382&r2=1127383&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/MetaUtils.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/util/MetaUtils.java Wed May 25 05:05:39 2011
@@ -225,7 +225,7 @@ public class MetaUtils {
info = Writables.getHRegionInfoOrNull(kv.getValue());
if (info == null) {
LOG.warn("Region info is null for row " +
- Bytes.toString(kv.getRow()) + " in table " +
+ Bytes.toStringBinary(kv.getRow()) + " in table " +
r.getTableDesc().getNameAsString());
}
continue;