| commit | 183507dd768ed9568dddd363d650127566573ae2 | [log] [tgz] |
|---|---|---|
| author | Alexey Goncharuk <alexey.goncharuk@gmail.com> | Fri May 18 12:43:48 2018 +0300 |
| committer | Alexey Goncharuk <alexey.goncharuk@gmail.com> | Fri May 18 12:43:48 2018 +0300 |
| tree | 9ba487fd476a0f82f876cf318a30b93e0c9b95c8 | |
| parent | fdad64189eb62bdcaf213d45483dc34b11e422d6 [diff] |
IGNITE-8521 Fixed NPE on continuous query register fail
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java index 19225f8..55c44b4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -703,7 +703,8 @@ catch (IgniteCheckedException e) { log.warning("Failed to start continuous query.", e); - cctx.kernalContext().continuous().stopRoutine(id); + if (id != null) + cctx.kernalContext().continuous().stopRoutine(id); throw new IgniteCheckedException("Failed to start continuous query.", e); }