From d1cd3f57a7647bfd437513f38e5cd790785893f4 Mon Sep 17 00:00:00 2001 From: Colin Surprenant Date: Wed, 24 Jul 2013 23:04:34 -0400 Subject: [PATCH] reduce parallelism --- examples/dsl/redis_word_count_topology.rb | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/examples/dsl/redis_word_count_topology.rb b/examples/dsl/redis_word_count_topology.rb index 9323584..0073cc4 100644 --- a/examples/dsl/redis_word_count_topology.rb +++ b/examples/dsl/redis_word_count_topology.rb @@ -38,7 +38,7 @@ module RedStorm class RedisWordCountTopology < DSL::Topology spout RedisWordSpout - bolt WordCountBolt, :parallelism => 3 do + bolt WordCountBolt, :parallelism => 2 do source RedisWordSpout, :fields => ["word"] end @@ -46,10 +46,10 @@ module RedStorm debug true case env when :local - max_task_parallelism 3 + max_task_parallelism 2 when :cluster - max_task_parallelism 5 - num_workers 20 + max_task_parallelism 2 + num_workers 2 max_spout_pending(1000) end end