This is an automated email from the ASF dual-hosted git repository. mpochatkin pushed a commit to branch IGNITE-26865 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 185ed71db7ca644ec0ad187a78ba361311a729fd Author: Pochatkin Mikhail <[email protected]> AuthorDate: Wed Nov 19 16:50:46 2025 +0300 IGNITE-26865 Fix cached deployment unit close --- .../ignite/internal/deployunit/CachedDeploymentUnit.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/CachedDeploymentUnit.java b/modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/CachedDeploymentUnit.java index e07d2a7529a..5f969958b9f 100644 --- a/modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/CachedDeploymentUnit.java +++ b/modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/CachedDeploymentUnit.java @@ -41,10 +41,14 @@ public class CachedDeploymentUnit implements DeploymentUnit { @Override public void close() throws Exception { future.whenComplete((unit, throwable) -> { - try { - unit.close(); - } catch (Exception e) { - LOG.warn("Failed to close deployment unit: {}", e, unit); + if (unit != null) { + try { + unit.close(); + } catch (Exception e) { + LOG.warn("Failed to close deployment unit: {}", e, unit); + } + } else { + LOG.info("Future to access cached unit is failed.", throwable); } }); }
