From c921ca28b6b59660a6795bce010feb35971b6cbe Mon Sep 17 00:00:00 2001 From: Dotan Nahum Date: Sun, 20 May 2012 00:08:32 +0300 Subject: [PATCH] Found real cause of #7. Look like java_import was introducing a class overwrite for 'Config', when `rbconfig` needed to be used (Config::CONFIG), the error would surface. rbconfig is used with rack utils. --- lib/red_storm/simple_topology.rb | 4 ++-- lib/red_storm/topology_launcher.rb | 6 +++++- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/lib/red_storm/simple_topology.rb b/lib/red_storm/simple_topology.rb index 6f203dc..fd0dd60 100644 --- a/lib/red_storm/simple_topology.rb +++ b/lib/red_storm/simple_topology.rb @@ -61,7 +61,7 @@ class Configurator attr_reader :config def initialize - @config = Config.new + @config = Backtype::Config.new end def method_missing(sym, *args) @@ -173,4 +173,4 @@ def self.underscore(camel_case) camel_case.to_s.split('::').last.gsub(/(.)([A-Z])/,'\1_\2').downcase! end end -end \ No newline at end of file +end diff --git a/lib/red_storm/topology_launcher.rb b/lib/red_storm/topology_launcher.rb index fc4b48b..1f95834 100644 --- a/lib/red_storm/topology_launcher.rb +++ b/lib/red_storm/topology_launcher.rb @@ -10,7 +10,11 @@ require 'red_storm' end -java_import 'backtype.storm.Config' +# see https://github.com/colinsurprenant/redstorm/issues/7 +module Backtype + java_import 'backtype.storm.Config' +end + java_import 'backtype.storm.LocalCluster' java_import 'backtype.storm.StormSubmitter' java_import 'backtype.storm.topology.TopologyBuilder'