issue #35, automatically set JRuby 1.8/1.9 mode in remote cluster context

This commit is contained in:
Colin Surprenant 2012-06-28 13:23:56 -04:00
parent 856d3e648f
commit bc57741485
2 changed files with 5 additions and 1 deletions

View File

@ -121,7 +121,10 @@ module RedStorm
bolt.define_grouping(declarer)
end
configurator = Configurator.new
# set the JRuby compatibility mode option for Storm workers, default to current JRuby mode
defaults = {"topology.worker.childopts" => "-Djruby.compat.version=#{RedStorm.jruby_mode_token}"}
configurator = Configurator.new(defaults)
configurator.instance_exec(env, &self.class.configure_block)
submitter = (env == :local) ? @cluster = LocalCluster.new : StormSubmitter

View File

@ -457,6 +457,7 @@ describe RedStorm::SimpleTopology do
Backtype::Config.should_receive(:new).and_return(config)
config.should_receive(:setDebug).with(true)
config.should_receive(:setMaxTaskParallelism).with(3)
config.should_receive(:put).with("topology.worker.childopts", "-Djruby.compat.version=#{RedStorm.jruby_mode_token}")
builder = mock(RedStorm::TopologyBuilder)
RedStorm::TopologyBuilder.should_receive(:new).and_return(builder)