Hi, I tried the example code of creating table and inserting the values to the table using storm jdbc example code.
Here source code I'm using https://github.com/apache/storm/tree/master/external/storm-jdbc/src/test code is working fine but when I increase the the parallelism of bolt above 11 or if I increase setNumtasks above 11 by keeping the bolt parallelism to 1,code is giving me run time exception. *java.lang.RuntimeException: Fail-fast during pool initialization* at com.zaxxer.hikari.pool.HikariPool.fillPool(HikariPool.java:475) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:159) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:112) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at com.zaxxer.hikari.HikariDataSource.<init>(HikariDataSource.java:78) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at Demo.ConnectionProvider.prepare(ConnectionProvider.java:26) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at Demo.AbstractJdbcBolt.prepare(AbstractJdbcBolt.java:24) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at Demo.PsqlBolt.prepare(PsqlBolt.java:76) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at backtype.storm.daemon.executor$fn__6647$fn__6659.invoke(executor.clj:692) ~[storm-core-0.9.5.jar:0.9.5] at backtype.storm.util$async_loop$fn__459.invoke(util.clj:461) ~[storm-core-0.9.5.jar:0.9.5] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_74] Caused by: org.postgresql.util.PSQLException:* FATAL: sorry, too many clients already* at org.postgresql.Driver$ConnectThread.getResult(Driver.java:361) ~[postgresql-9.3-1102-jdbc4.jar:na] at org.postgresql.Driver.connect(Driver.java:284) ~[postgresql-9.3-1102-jdbc4.jar:na] at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[na:1.8.0_74] at java.sql.DriverManager.getConnection(DriverManager.java:247) ~[na:1.8.0_74] at org.postgresql.ds.common.BaseDataSource.getConnection(BaseDataSource.java:99) ~[postgresql-9.3-1102-jdbc4.jar:na] at org.postgresql.ds.common.BaseDataSource.getConnection(BaseDataSource.java:82) ~[postgresql-9.3-1102-jdbc4.jar:na] at com.zaxxer.hikari.pool.HikariPool.addConnection(HikariPool.java:398) ~[storm-streaming-1.0-SNAPSHOT.jar:na] at com.zaxxer.hikari.pool.HikariPool.fillPool(HikariPool.java:474) ~[storm-streaming-1.0-SNAPSHOT.jar:na] storm topology is taking all the max connections of db. can some one explain why storm is taking all the connections and throwing run time exception.
