Author: stack
Date: Fri Sep 23 17:41:26 2011
New Revision: 1174909
URL: http://svn.apache.org/viewvc?rev=1174909&view=rev
Log:
HBASE-4387 Error while syncing: DFSOutputStream is closed
Modified:
hbase/branches/0.92/CHANGES.txt
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
Modified: hbase/branches/0.92/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1174909&r1=1174908&r2=1174909&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Fri Sep 23 17:41:26 2011
@@ -624,6 +624,8 @@ Release 0.90.5 - Unreleased
HBASE-4445 Not passing --config when checking if distributed mode or not
HBASE-4453 TestReplication failing up on builds.a.o because already
running zk with new format root servername
+ HBASE-4387 Error while syncing: DFSOutputStream is closed
+ (Lars Hofhansl)
IMPROVEMENT
HBASE-4205 Enhance HTable javadoc (Eric Charles)
Modified:
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
URL:
http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java?rev=1174909&r1=1174908&r2=1174909&view=diff
==============================================================================
---
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
(original)
+++
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
Fri Sep 23 17:41:26 2011
@@ -1061,8 +1061,17 @@ public class HLog implements Syncable {
try {
long now = System.currentTimeMillis();
// Done in parallel for all writer threads, thanks to HDFS-895
- this.writer.sync();
+ boolean syncSuccessful = true;
+ try {
+ this.writer.sync();
+ } catch(IOException io) {
+ syncSuccessful = false;
+ }
synchronized (this.updateLock) {
+ if (!syncSuccessful) {
+ // HBASE-4387, retry with updateLock held
+ this.writer.sync();
+ }
syncTime += System.currentTimeMillis() - now;
syncOps++;
if (!this.logRollRunning) {
