IGNITE-2683
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e29b1a58 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e29b1a58 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e29b1a58 Branch: refs/heads/ignite-2683 Commit: e29b1a583f6fe31fd8bd7c0a23b80e0e489a6876 Parents: c1e5999 Author: Anton Vinogradov <[email protected]> Authored: Fri Feb 19 18:41:01 2016 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Feb 19 18:41:01 2016 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e29b1a58/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index 0324e41..fc14e82 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -1244,7 +1244,7 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler if (dep == null) throw new IgniteDeploymentCheckedException("Failed to obtain deployment for class: " + clsName); - return ctx.config().getMarshaller().unmarshal(bytes, dep.classLoader()); + return ctx.config().getMarshaller().unmarshal(bytes, U.resolveClassLoader(dep.classLoader(), ctx.config())); } /** {@inheritDoc} */
