#ignite-743: IsolatedUpdater should wait cache started.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ecf963e4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ecf963e4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ecf963e4 Branch: refs/heads/ignite-758 Commit: ecf963e4de1cc508d213170802515a20d7543396 Parents: 8ee275f Author: ivasilinets <ivasilin...@gridgain.com> Authored: Wed Apr 15 14:54:48 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Wed Apr 15 14:54:48 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/datastreamer/DataStreamerImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ecf963e4/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java index 83fb3cb..0486bed 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java @@ -1375,6 +1375,13 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed Collection<Map.Entry<KeyCacheObject, CacheObject>> entries) { IgniteCacheProxyLockFree<KeyCacheObject, CacheObject> proxy = (IgniteCacheProxyLockFree<KeyCacheObject, CacheObject>)cache; + try { + proxy.context().awaitStarted(); + } + catch (IgniteCheckedException e) { + U.convertException(e); + } + GridCacheAdapter<KeyCacheObject, CacheObject> internalCache = proxy.context().cache(); if (internalCache.isNear())
