storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Harsha <m...@harsha.io>
Subject Re: supervisor.slots.port setup from storm config
Date Fri, 05 Dec 2014 16:36:19 GMT


my bad its in 0.9.3 and not in 0.9.2. In 0.9.2 workers uses cluster.xml
so you can add your log4j changes there.

On Fri, Dec 5, 2014, at 07:55 AM, Kushan Maskey wrote:
> Harsh,
>
> I could not find worker.xml in my storm package. Does it come with
> storm 0.9.2 package? Thanks.
>
> --
> Kushan Maskey
> 817.403.7500
> M. Miller & Associates[1] kushan.maskey@mmillerassociates.com
>
> On Thu, Dec 4, 2014 at 12:11 PM, Kushan Maskey
> <kushan.maskey@mmillerassociates.com> wrote:
>> I have not and I think I will try that. I will keep you posted.
>>
>> Thanks.
>>
>>
>> --
>> Kushan Maskey
>> 817.403.7500
>>
>> M. Miller & Associates[2] kushan.maskey@mmillerassociates.com
>>
>>
>> On Thu, Dec 4, 2014 at 11:30 AM, Harsha <storm@harsha.io> wrote:
>>> __
>>>
>>> Kushan, Did you try modifying logback/worker.xml . Since you have
>>> multiple topologies if they have distinct java packages you can add
>>> per package log4j config to worker.xml . You probably might see
>>> duplicate logging in worker-port.log files additional to the
>>> topology log files. Thats one way I would try separating out
>>> topology logging .
>>>
>>> -Harsha
>>>
>>>
>>> On Thu, Dec 4, 2014, at 09:23 AM, Parth Brahmbhatt wrote:
>>>> Harsha is right, if you are trying to do this as part of topology
>>>> submission, even though the param will get accepted it will have no
>>>> effect. On Dec 4, 2014, at 9:01 AM, Parth Brahmbhatt
>>>> <pbrahmbhatt@hortonworks.com> wrote:
>>>>
>>>>> As the error suggests it needs to be an utterable, you can add it
>>>>> by using the following line, the second arg must be a collection.
>>>>> *config.put(Config.SUPERVISOR_SLOTS_PORTS,
>>>>> Lists.newArrayList(7000));*
>>>>>
>>>>> On Dec 4, 2014, at 8:58 AM, Kushan Maskey
>>>>> <kushan.maskey@mmillerassociates.com> wrote:
>>>>>
>>>>>> Is there a way I can set supervisor_slots_port in the config in
>>>>>> the topology class? I tried to set it up like below
>>>>>>
>>>>>> *config.put(Config.SUPERVISOR_SLOTS_PORTS, 7000);*
>>>>>>
>>>>>> but I get error as below. *InvalidTopologyException(msg:Field
>>>>>> supervisor.slots.ports must be an Iterable of java.lang.Number*


>>>>>> Thanks.
>>>>>>
>>>>>> --
>>>>>> Kushan Maskey
>>>>>> 817.403.7500
>>>>>> M. Miller & Associates[3] kushan.maskey@mmillerassociates.com
>>>>>
>>>>
>>>>
>>>> CONFIDENTIALITY NOTICE NOTICE: This message is intended for the use
>>>> of the individual or entity to which it is addressed and may
>>>> contain information that is confidential, privileged and exempt
>>>> from disclosure under applicable law. If the reader of this message
>>>> is not the intended recipient, you are hereby notified that any
>>>> printing, copying, dissemination, distribution, disclosure or
>>>> forwarding of this communication is strictly prohibited. If you
>>>> have received this communication in error, please contact the
>>>> sender immediately and delete it from your system. Thank You.
>>>
>>
>



Links:

  1. http://mmillerassociates.com/
  2. http://mmillerassociates.com/
  3. http://mmillerassociates.com/

Mime
View raw message