Praneeth K Naramsetti

It does not work on my centos 7.2 . But with this change it is working fine. I also think the start and stop should also accommodate this change.

While this fix solves this bug, i think it creates a new one. Lets suppose we have : Source(**_).name("dummySrc").map ( fn ). name ("dummyOpt").sumByKey(**_*) Options.set("dummySrc"->SummerParallelism(10)) Which gets converted to :...

@pankajroark As the code for the 'get' method is in StormPlatform, we can use case statements to see if it's a SourceNode/SummerNode and try to collect the SourceProducer/SummerProducer and then...