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

HBASE-24574 Procedure V2 - Distributed WAL Splitting => LOGGING (#1912) 

Addendum 2 fix compile error.
This commit is contained in:
stack 2020-06-18 08:49:39 -07:00
parent 489f07d945
commit 537a3caccd
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitLogWorker.java
View File

@ -183,24 +183,24 @@ public class SplitLogWorker implements Runnable {
return Status.PREEMPTED; return Status.PREEMPTED;
} }
} catch (InterruptedIOException iioe) { } catch (InterruptedIOException iioe) {
LOG.warn("Resigning, interrupted splitting WAL {}", filename, iioe); LOG.warn("Resigning, interrupted splitting WAL {}", name, iioe);
return Status.RESIGNED; return Status.RESIGNED;
} catch (IOException e) { } catch (IOException e) {
if (e instanceof FileNotFoundException) { if (e instanceof FileNotFoundException) {
// A wal file may not exist anymore. Nothing can be recovered so move on // A wal file may not exist anymore. Nothing can be recovered so move on
LOG.warn("Done, WAL {} does not exist anymore", filename, e); LOG.warn("Done, WAL {} does not exist anymore", name, e);
return Status.DONE; return Status.DONE;
} }
Throwable cause = e.getCause(); Throwable cause = e.getCause();
if (e instanceof RetriesExhaustedException && (cause instanceof NotServingRegionException if (e instanceof RetriesExhaustedException && (cause instanceof NotServingRegionException
|| cause instanceof ConnectException || cause instanceof SocketTimeoutException)) { || cause instanceof ConnectException || cause instanceof SocketTimeoutException)) {
LOG.warn("Resigning, can't connect to target regionserver splitting WAL {}", filename, e); LOG.warn("Resigning, can't connect to target regionserver splitting WAL {}", name, e);
return Status.RESIGNED; return Status.RESIGNED;
} else if (cause instanceof InterruptedException) { } else if (cause instanceof InterruptedException) {
LOG.warn("Resigning, interrupted splitting WAL {}", filename, e); LOG.warn("Resigning, interrupted splitting WAL {}", name, e);
return Status.RESIGNED; return Status.RESIGNED;
} }
LOG.warn("Error splitting WAL {}", filename, e); LOG.warn("Error splitting WAL {}", name, e);
return Status.ERR; return Status.ERR;
} }
return Status.DONE; return Status.DONE;