You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/11/03 13:45:00 UTC
ignite git commit: IGNITE-950 - Use keepBinary for platform streamer.
Repository: ignite
Updated Branches:
refs/heads/ignite-950-new 86e75ff3a -> bb864c67f
IGNITE-950 - Use keepBinary for platform streamer.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/bb864c67
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/bb864c67
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/bb864c67
Branch: refs/heads/ignite-950-new
Commit: bb864c67f159e666a8db2e74158298baf8611dc8
Parents: 86e75ff
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Nov 3 15:44:50 2015 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Nov 3 15:44:50 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/platform/PlatformProcessorImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/bb864c67/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessorImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessorImpl.java
index 664067c..27d7da3 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessorImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessorImpl.java
@@ -253,7 +253,7 @@ public class PlatformProcessorImpl extends GridProcessorAdapter implements Platf
throws IgniteCheckedException {
IgniteDataStreamer ldr = ctx.dataStream().dataStreamer(cacheName);
- ldr.keepBinary(keepPortable);
+ ldr.keepBinary(true);
return new PlatformDataStreamer(platformCtx, cacheName, (DataStreamerImpl)ldr, keepPortable);
}