1 files changed, 4 insertions, 0 deletions
diff --git a/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java b/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
index 2064e68..e660162 100644
--- a/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
+++ b/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
@@ -24,6 +24,7 @@ import java.nio.channels.ClosedByInterruptException;
 import com.amazon.carbonado.FetchException;
 import com.amazon.carbonado.FetchInterruptedException;
 import com.amazon.carbonado.PersistException;
+import com.amazon.carbonado.PersistInterruptedException;
 import com.amazon.carbonado.RepositoryException;
 
 /**
@@ -158,6 +159,9 @@ public class ExceptionTransformer {
         if (e instanceof PersistException) {
             return (PersistException) e;
         }
+        if (e instanceof InterruptedIOException) {
+            return new PersistInterruptedException(e);
+        }
         if (e instanceof FetchException) {
             return ((FetchException) e).toPersistException();
         }