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

HBASE-453 undeclared throwable exception from HTable.get 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@654256 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jim Kellerman 2008-05-07 20:19:53 +00:00
parent eaa03f245b
commit 4aa78f4f28
2 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -34,6 +34,7 @@ Hbase Change Log
HBASE-618 We always compact if 2 files, regardless of the compaction threshold setting HBASE-618 We always compact if 2 files, regardless of the compaction threshold setting
HBASE-619 Fix 'logs' link in UI HBASE-619 Fix 'logs' link in UI
HBASE-478 offlining of table does not run reliably HBASE-478 offlining of table does not run reliably
HBASE-453 undeclared throwable exception from HTable.get
IMPROVEMENTS IMPROVEMENTS
HBASE-559 MR example job to count table rows HBASE-559 MR example job to count table rows

23
src/java/org/apache/hadoop/hbase/ipc/HbaseRPC.java
View File

@ -205,13 +205,24 @@ public class HbaseRPC {
} }
public Object invoke(Object proxy, Method method, Object[] args) public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable { throws IOException {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
HbaseObjectWritable value = (HbaseObjectWritable) try {
client.call(new Invocation(method, args), address, ticket); HbaseObjectWritable value = (HbaseObjectWritable)
long callTime = System.currentTimeMillis() - startTime; client.call(new Invocation(method, args), address, ticket);
LOG.debug("Call: " + method.getName() + " " + callTime); long callTime = System.currentTimeMillis() - startTime;
return value.get(); LOG.debug("Call: " + method.getName() + " " + callTime);
return value.get();
} catch (Throwable t) {
IOException e;
if (t instanceof IOException) {
e = (IOException) t;
} else {
e = new IOException("error during RPC call");
e.initCause(t);
}
throw e;
}
} }
} }