diff --git a/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/cas/OCASDiskWriteAheadLog.java b/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/cas/OCASDiskWriteAheadLog.java index 79b2e6b34e0..45a575b714e 100755 --- a/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/cas/OCASDiskWriteAheadLog.java +++ b/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/paginated/wal/cas/OCASDiskWriteAheadLog.java @@ -54,6 +54,7 @@ import java.util.NavigableSet; import java.util.TreeMap; import java.util.concurrent.Callable; +import java.util.concurrent.CancellationException; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentSkipListMap; @@ -1417,6 +1418,8 @@ public void close(final boolean flush) throws IOException { try { recordsWriterFuture.get(); + } catch (CancellationException e) { + //ignoring, we cancelled scheduled task few lines above } catch (InterruptedException | ExecutionException e) { throw OException.wrapException( new OStorageException("Error during writing of WAL records in storage " + storageName),