Re: Using FLUX and multiple streams to the same bolt

JIRA: https://issues.apache.org/jira/browse/STORM-873 On Jun 17, 2015, at 11:38 PM, P. Taylor Goetz wrote: > Romeo, > > I have a fix (see below). Should be included in the next release (beta or > final). I will follow up with a JIRA ID for tracking. > > -- TOPOLOGY DETAILS --

Re: Using FLUX and multiple streams to the same bolt

Romeo, I have a fix (see below). Should be included in the next release (beta or final). I will follow up with a JIRA ID for tracking. -- TOPOLOGY DETAILS -- Topology Name: diamond-topology --- SPOUTS --- spout-1 [1] (backtype.storm.testing.TestWordSpout)

Re: stumped with local-mode stack overflow error

We’ve tried from 0.9.3 to 0.9.5. Our topology uses a lot of Java 8 constructs (streams + optionals) so we can’t run it under 1.8 without a lot of refactoring. Typically we run the topology main class from inside IntelliJ or a shell, here’s the main: public static void main(String[] args) t

Re: stumped with local-mode stack overflow error

Strange... What version of storm? Looks like you are on OSX and have Java 1.8, have you tried forcing Java 1.7? How are you running in local mode? The more details you can give, the better. Code to reproduce the issue would be ideal. -Taylor > On Jun 17, 2015, at 3:08 PM, David Maldonado w

Re: stumped with local-mode stack overflow error

What seem to be seeing the the local dir’s path is getting changed. First print of the path in the log /var/folders/8y/nhzb5c7x675grfn2gr84rk08gn/T/7290a78f-c318-47f8-974d-5f8be0630783 Second print of the path in the log /var/folders/8y/nhzb5c7x675grfn2gr84rk08gn/T//7290a78f-c31

CountMetric values showed up from just one topology when there are two identical topologies running

I have two identical topologies running in the same remote cluster. They are the exact same classes with a different topology name and different sources/sinks; therefore their CountMetric names are the same. Each topology has one executor for __metricsbacktype.storm.metric.LoggingMetricsConsumer an

Re: Singleton database connection

You cannot pass a connection through the builder, as you have noticed. You can use a lazy initialized singleton or some sort of connection pool. On Jun 17, 2015 5:05 PM, "Kushan Maskey" < kushan.mas...@mmillerassociates.com> wrote: > I am wondering how can I safely create a Singleton database conn

Singleton database connection

I am wondering how can I safely create a Singleton database connection and use it through out the process. Here is my scenario. I got bunch of bolts that updates Cassandra database. I have reader and writer classes where each needs a database session to execute queries. We create session on each

Re: Using FLUX and multiple streams to the same bolt

Hi Romeo, Thanks for reporting that. It’s a bug, and your approach for a fix is correct. If you’d like, feel free to open a JIRA and optionally a pull request for a fix. Otherwise, I can take care of it. -Taylor On Jun 17, 2015, at 4:07 PM, Romeo Nocon wrote: > Hi, > > I'm testing migrating

Using FLUX and multiple streams to the same bolt

Hi, I'm testing migrating over a topology I have to flux. The spout: - id: "spout" bolts: - id: "bolt_A" className: "com.blah.boltA" parallelism: 1 - id: "bolt_B" className: "com.blah.boltB" parallelism: 1 - id: "bolt_C" className: "com.blah.boltC" parallelism: 1

stumped with local-mode stack overflow error

Hello all, I’m having a nasty issue in local-mode only where I’m getting a stack overflow error when jdk libraries are getting copied over to the supervisor, any help would be greatly appreciated! David Maldonado Evident.io 4744 [main] INFO backtype.storm.daemon.supervisor - Starting supervi