Fixed IgniteTransactionalWriteInvokeBenchmark
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e5de23e9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e5de23e9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e5de23e9 Branch: refs/heads/ignite-1.5.1 Commit: e5de23e9b61acc435ead4e70be9970a307906dbb Parents: 11d668b Author: ashutak <ashu...@gridgain.com> Authored: Fri Dec 4 12:11:15 2015 +0300 Committer: ashutak <ashu...@gridgain.com> Committed: Fri Dec 4 12:11:15 2015 +0300 ---------------------------------------------------------------------- .../IgniteTransactionalWriteInvokeBenchmark.java | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e5de23e9/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java index 9f9b5f7..35befad 100644 --- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java +++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java @@ -68,17 +68,15 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr long start = System.nanoTime(); - if (cfg.memberId() == 0) { - try (IgniteDataStreamer<String, Long> dataLdr = ignite().dataStreamer(cacheName())) { - for (int k = 0; k < args.range() && !Thread.currentThread().isInterrupted(); k++) { - dataLdr.addData("key-" + k + "-master", INITIAL_VALUE); + try (IgniteDataStreamer<String, Long> dataLdr = ignite().dataStreamer(cacheName())) { + for (int k = 0; k < args.range() && !Thread.currentThread().isInterrupted(); k++) { + dataLdr.addData("key-" + k + "-master", INITIAL_VALUE); - for (int i = 0; i < args.keysCount(); i++) - dataLdr.addData("key-" + k + "-" + i, INITIAL_VALUE); + for (int i = 0; i < args.keysCount(); i++) + dataLdr.addData("key-" + k + "-" + i, INITIAL_VALUE); - if (k % 100000 == 0) - println(cfg, "Populated accounts: " + k); - } + if (k % 100000 == 0) + println(cfg, "Populated accounts: " + k); } }