Repository: ignite Updated Branches: refs/heads/ignite-5658 b16455779 -> e9b851ae4
ignite-5658 disabling striped pool for benchmarks Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e9b851ae Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e9b851ae Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e9b851ae Branch: refs/heads/ignite-5658 Commit: e9b851ae49a4aaebc8eae8161e76a0389edfc8ec Parents: b164557 Author: Yakov Zhdanov <[email protected]> Authored: Tue Aug 1 10:38:43 2017 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Tue Aug 1 10:38:43 2017 +0300 ---------------------------------------------------------------------- .../internal/processors/datastreamer/DataStreamerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e9b851ae/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 6e9fbb5..9d56668 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 @@ -1716,8 +1716,8 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed rcvr == ISOLATED_UPDATER ? partId : GridIoMessage.STRIPE_DISABLED_PART); try { - ctx.io().sendToGridTopic(node, TOPIC_DATASTREAM, req, - req.partition() == GridIoMessage.STRIPE_DISABLED_PART ? plc : GridIoPolicy.SYSTEM_POOL); + ctx.io().sendToGridTopic(node, TOPIC_DATASTREAM, req, plc); // TODO +// req.partition() == GridIoMessage.STRIPE_DISABLED_PART ? plc : GridIoPolicy.SYSTEM_POOL); if (log.isDebugEnabled()) log.debug("Sent request to node [nodeId=" + node.id() + ", req=" + req + ']');
