File tree Expand file tree Collapse file tree
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3232import org .apache .hadoop .fs .Path ;
3333import org .apache .hadoop .hbase .Cell ;
3434import org .apache .hadoop .hbase .HBaseConfiguration ;
35+ import org .apache .hadoop .hbase .exceptions .TimeoutIOException ;
3536import org .apache .hadoop .hbase .io .ByteBufferWriter ;
3637import org .apache .hadoop .hbase .io .asyncfs .AsyncFSOutput ;
3738import org .apache .hadoop .hbase .io .asyncfs .AsyncFSOutputHelper ;
@@ -205,9 +206,11 @@ private long writeWALMetadata(Consumer<CompletableFuture<Long>> action) throws I
205206 InterruptedIOException ioe = new InterruptedIOException ();
206207 ioe .initCause (e );
207208 throw ioe ;
208- } catch (ExecutionException | TimeoutException e ) {
209+ } catch (ExecutionException e ) {
209210 Throwables .propagateIfPossible (e .getCause (), IOException .class );
210211 throw new RuntimeException (e .getCause ());
212+ } catch (TimeoutException e ) {
213+ throw new TimeoutIOException (e );
211214 }
212215 }
213216
You can’t perform that action at this time.
0 commit comments