You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2009/08/25 20:31:02 UTC
svn commit: r807751 - in /hadoop/hbase/branches/0.20: CHANGES.txt
src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java
Author: apurtell
Date: Tue Aug 25 18:31:02 2009
New Revision: 807751
URL: http://svn.apache.org/viewvc?rev=807751&view=rev
Log:
HBASE-1791 Timeout in IndexRecordWriter
Modified:
hadoop/hbase/branches/0.20/CHANGES.txt
hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java
Modified: hadoop/hbase/branches/0.20/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.20/CHANGES.txt?rev=807751&r1=807750&r2=807751&view=diff
==============================================================================
--- hadoop/hbase/branches/0.20/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.20/CHANGES.txt Tue Aug 25 18:31:02 2009
@@ -325,6 +325,8 @@
new updates into the 'kvset' (active part)
HBASE-1767 test zookeeper broken in trunk and 0.20 branch; broken on
hudson too
+ HBASE-1791 Timeout in IndexRecordWriter (Bradford Stephens via Andrew
+ Purtell)
IMPROVEMENTS
HBASE-1089 Add count of regions on filesystem to master UI; add percentage
Modified: hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java?rev=807751&r1=807750&r2=807751&view=diff
==============================================================================
--- hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java (original)
+++ hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java Tue Aug 25 18:31:02 2009
@@ -136,9 +136,14 @@
*/
@Override
public void run() {
- while (!closed) {
try {
- context.setStatus("closing");
+ context.setStatus("Closing");
+ } catch (IOException e) {
+ return;
+ }
+ while (!closed) {
+ try {
+ context.progress();
Thread.sleep(1000);
} catch (InterruptedException e) {
continue;