Re: Native Streaming Window API

Thanks a lot Koji. Appreciate the effort ! On Wed, Oct 5, 2016 at 9:26 AM, Koji Ishida wrote: > Hi. > > Sorry for late reply. > > I translated previous my posting in English. > > I wish that is helpful for my friends all over the world :) > >

RE: Nimbus setting java.class.path to include javaagent

Hey Taylor,Sorry, that path was from my development machine. On the nimbus server in question storm.classpath

RE: Nimbus setting java.class.path to include javaagent

That may be the case. I have confirmed that supervisor is getting either the Client classpath or Server classpath sent to zookeeper to start worker processes. If I edit the config file on the supervisor, the workers still start with the classpath that is on the nimbus server, with the

Re: Nimbus setting java.class.path to include javaagent

What your seeing is the ZooKeeper client running within Nimbus/Supervisor just printing out it’s class path, which it inherits from Storm’s class path. It’s not really sending that to ZooKeeper. What’s weird is that the agent jar sneaking onto the class path. On your supervisor node, can you

How to iterate through mongodb under Storm + Trident

Hi there, I'm using storm 1.0.1. I have user case like this, given one signal (received from kafka spout), fetch a bunch of users (in mongodb), then do stream processing. I'd prefer trident since the lambda like language is so convenient. But don't have good idea about iterating through mongodb.

Storm topology Searchscrll elasticsearch

I have a problem with elasticsearch scroll search. I use storm topology to index my documents in an other index, i used a scrollsearch to get documents from index, my question is when I run topology in local cluster all documents were successfully indexed and I don't get duplicates documents from

Re: Native Streaming Window API

Hi. Sorry for late reply. I translated previous my posting in English. I wish that is helpful for my friends all over the world :) http://qiita.com/kojiisd/items/1618cf8d79bb5ed995d3#english-translation Regards, Koji

Meaning of Metric Values

Hello, I'm curious about Storm Metrics but I'm unsure if I'm interpreting the values correctly. The following are two "Samples" for testing purposes (3 seconds between them). 2016-10-05 12:25:36.881 s.m.m.LoggingMetricsConsumer [INFO] TaskInfo: - Worker Port: 31000 - Component ID: split -