Skip to content

Commit 61923cd

Browse files
committed
IGNITE-28000 Add CancelationException to ViewUtils#sync
1 parent 1d7e3ed commit 61923cd

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • modules/core/src/main/java/org/apache/ignite/internal/util

modules/core/src/main/java/org/apache/ignite/internal/util/ViewUtils.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import java.lang.invoke.MethodType;
2727
import java.util.Collection;
2828
import java.util.Objects;
29+
import java.util.concurrent.CancellationException;
2930
import java.util.concurrent.CompletableFuture;
3031
import java.util.concurrent.ExecutionException;
3132
import java.util.function.Function;
@@ -52,7 +53,7 @@ public static <T> T sync(CompletableFuture<T> fut) {
5253
Thread.currentThread().interrupt(); // Restore interrupt flag.
5354

5455
throw sneakyThrow(ensurePublicException(e));
55-
} catch (ExecutionException e) {
56+
} catch (ExecutionException | CancellationException e) {
5657
Throwable cause = unwrapCause(e);
5758

5859
throw sneakyThrow(ensurePublicException(cause));

0 commit comments

Comments
 (0)