Re: Storm topology using all the Max connections of db

Hi, I just added a statement * // config.setMaximumPoolSize(50);* public synchronized void prepare() { if(dataSource == null) { Properties properties = new Properties(); properties.putAll(configMap); HikariConfig config = new

Re: Storm topology using all the Max connections of db

Hi, Thank you Spico Florin. *Best regards,* *K.Sai Dilip Reddy.* On Wed, May 4, 2016 at 1:18 AM, Spico Florin wrote: > hi! > please have a look > https://github.com/apache/storm/tree/master/external/storm-jdbc where you > hve to implemnt thw interface

Re: Storm topology using all the Max connections of db

hi! please have a look https://github.com/apache/storm/tree/master/external/storm-jdbc where you hve to implemnt thw interface connectionprovider interface. you have to dins a third paty librry that provides conection pooloing for postgresql and use that library to implement the interface

RE: Storm 1.0.0 upgrade Serialization issue

Hi, we had a similar issue (see https://mail-archives.apache.org/mod_mbox/storm-user/201604.mbox/%3C645fd70cb0874be0ac1f1e41a0f9393b%40SG001741.corproot.net%3E ). So far, we have not been able to solve it, but we currently have a suspicion that it might be related to the Jackson ObjectMapper we

Storm 1.0.0 upgrade Serialization issue

Hello, We have recently upgraded to Storm 1.0.0. Our system was in production for long with Storm 0.9. Our topology is not getting loaded with this upgrade. It was working fine with 0.9. I am getting following error: ---

Re: Un excellent outil pour votre smartphone android

C'est spam.

Re: Is Storm 1.0.0 compatible with Kafka 0.8.2.x?

No, KafkaSpout seems to be waiting, will need to take closer look. On Tue, May 3, 2016 at 11:22 AM, Abhishek Agarwal wrote: > Yes. data was flowing in. Do you see any exceptions? > > On Tue, May 3, 2016 at 6:11 PM, John Yost wrote: > >> Hey Abhishek,

Re: Is Storm 1.0.0 compatible with Kafka 0.8.2.x?

Yes. data was flowing in. Do you see any exceptions? On Tue, May 3, 2016 at 6:11 PM, John Yost wrote: > Hey Abhishek, > > Cool, yeah, switched my kafka dependency (my topo reads and writes to > Kafka) to 0.8.2.1 and everything deploys correctly. The next issue I am >

Re: Is Storm 1.0.0 compatible with Kafka 0.8.2.x?

Hey Abhishek, Cool, yeah, switched my kafka dependency (my topo reads and writes to Kafka) to 0.8.2.1 and everything deploys correctly. The next issue I am encountering is no data is flowing through the KafkaSpout. Do you have data flowing in your topo? --John On Mon, May 2, 2016 at 7:17 AM,

Un excellent outil pour votre smartphone android

Voulez-vous savoir si oui ou non le wifi sur lequel vous êtes connecté vous permet réellement d'accéder à internet? Voulez-vous savoir si votre réseau mobile vous permet réellement d'accéder à internet? Voulez vous un rendu en temps réel sur l'état de l'accès à internet sur votre smartphone? Ne

Re: Storm topology using all the Max connections of db

I'm using storm jdbc for connecting to db.how can I use pooling on codes on topology.please share information on connection pooling used on storm topologies. *Best regards,* *K.Sai Dilip Reddy.* On Thu, Apr 28, 2016 at 12:28 PM, Sai Dilip Reddy Kiralam < dkira...@aadhya-analytics.com> wrote:

Re: Why tuples fail in spout

Hi! It could be that your process time for that tuples is greater than topology.message.timeout.secs 30 seconds. In these case have a look at your bolts processing time or how fast you generate your data from spout that could not cope with your bolts. You can: 1. Increase your level your

Re: Why tuples fail in spout

but no failed count is shown for bolts *Best regards,* *K.Sai Dilip Reddy.* On Tue, May 3, 2016 at 11:19 AM, John Fang wrote: > Some tuples failed in the bolts. You can review the bolts' code. Maybe > your bolts' code trigger the fail() due to some reasons, Or

Re: [DISCUSS] Would like to make collective intelligence about Metrics on Storm

Harsha, Yes sure, I applied regex for filtering by metric name. Please refer relevant unit test from pull request . I'm