ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: Fixed exception conversion in DataStreamerImpl.
Date Fri, 16 Jun 2017 06:36:50 GMT
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 <sboikov@gridgain.com>
Authored: Fri Jun 16 09:36:40 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
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} */


Mime
View raw message