Compare NDB Exception using error codes
@@ -2415,16 +2415,12 @@ public synchronized void close() throws IOException {
closeInternal();
// get last block before destroying the streamer
} catch (ClosedChannelException e) {
- } catch (RemoteException e ) {
- IOException outOfDBExtents =
- e.unwrapRemoteException(OutOfDBExtentsException.class);
- if (outOfDBExtents == e) {
+ } catch (OutOfDBExtentsException e ) {
currentPacket = null;
forwardSmallFilesPacketsToDataNodes(); // try to store the file on
bytesCurBlock=0;
closeInternal();
}
- }
finally {
closed = true;
}
