Fix query timeout in distributed
uniform exception handling
@@ -1881,7 +1881,14 @@ public class ODatabaseDocumentEmbedded extends ODatabaseDocumentAbstract
@Override
public void interruptExecution(Thread thread) {
+ if (storage instanceof OAbstractPaginatedStorage) {
((OAbstractPaginatedStorage) storage).interruptExecution(thread);
+ } else {
+ OStorage underlying = storage.getUnderlying();
+ if (underlying != null && underlying instanceof OAbstractPaginatedStorage) {
+ ((OAbstractPaginatedStorage) underlying).interruptExecution(thread);
+ }
+ }
}
public boolean isCommandInterrupted() {
