You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/05 04:28:26 UTC
[34/66] [abbrv] ignite git commit: IGNITE-950 - Use keepBinary for
platform streamer.
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-1753-1282
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);
}