Repository: ignite Updated Branches: refs/heads/master 14f958b43 -> d16e22c3a
Fixed exception conversion in DataStreamerImpl. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d16e22c3 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d16e22c3 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d16e22c3 Branch: refs/heads/master Commit: d16e22c3af0411ff8bc88d0e1cd029d0da79e0b9 Parents: 14f958b Author: sboikov <[email protected]> Authored: Fri Jun 16 09:36:40 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Jun 16 09:36:40 2017 +0300 ---------------------------------------------------------------------- .../processors/datastreamer/DataStreamerImpl.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d16e22c3/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 48cacca..a991385 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 @@ -659,15 +659,18 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed else checkSecurityPermission(SecurityPermission.CACHE_PUT); - try { - KeyCacheObject key0 = cacheObjProc.toCacheKeyObject(cacheObjCtx, null, key, true); - CacheObject val0 = cacheObjProc.toCacheObject(cacheObjCtx, val, true); + KeyCacheObject key0; + CacheObject val0; - return addDataInternal(Collections.singleton(new DataStreamerEntry(key0, val0))); + try { + key0 = cacheObjProc.toCacheKeyObject(cacheObjCtx, null, key, true); + val0 = cacheObjProc.toCacheObject(cacheObjCtx, val, true); } catch (Exception e) { return new IgniteFinishedCacheFutureImpl<>(e); } + + return addDataInternal(Collections.singleton(new DataStreamerEntry(key0, val0))); } /** {@inheritDoc} */
