Re: RedisConnectionPoolService - Incorrectly Attempts to Connect to localhost
Hello, This should be fixed in master, just hasn’t been released yet. https://issues.apache.org/jira/browse/NIFI-5830 Bryan On Sat, Jan 26, 2019 at 8:04 AM wrote: > FYI > > > > I’ve just created a bugreport – I don’t think this is expected behavior. > https://issues.apache.org/jira/browse/NIFI-5976 > > > > I’ve also described a workaround in there. > > > > Cheers Josef > > > > > > *From: *"Zahner Josef, GSB-LR-TRW-LI" > *Date: *Saturday, 26 January 2019 at 13:07 > *To: *"users@nifi.apache.org" > *Subject: *Re: RedisConnectionPoolService - Incorrectly Attempts to > Connect to localhost > > > > Hi Jim > > > > Did you solve the issue? I have exactly the same behavior… I wanted to try > Redis but ended up with this error. > > > > Cheers Josef > > > > > > On 2018/11/29 21:54:25, "Williams, Jim" wrote: > > > Hello,> > > > > > > > > > > > > > I'm trying to set up the> > > > RedisConnectionPoolService/RedisDistributedMapCacheClientService.> > > > > > > > > > > > > > Some basic observations:> > > > > > > * This is a standalone Nifi 1.8.0 server> > > > * SELinux is disabled on the server> > > > * There are no iptables rules configured for blocking on the > server> > > > * I am able to resolve the hostname of the Redis server to an > IP> > > > address on the Nifi server> > > > * I can connect to the Redis server to the Nifi server using > telnet> > > > > > > > > > > > > > The stack trace I see when the services are started is:> > > > > > > 2018-11-29 21:16:03,527 WARN [Timer-Driven Process Thread-8]> > > > o.a.n.controller.tasks.ConnectableTask Administratively Yielding> > > > PutDistributedMapCache[id=0167105c-4a54-1adf-cb8d-1b45de7f0c99] due to> > > > uncaught Exception: org.springframework.data.redis.RedisConnection> > > > > > > FailureException: Cannot get Jedis connection; nested exception is> > > > redis.clients.jedis.exceptions.JedisConnectionException: Could not get > a> > > > resource from the pool> > > > > > > org.springframework.data.redis.RedisConnectionFailureException: Cannot > get> > > > Jedis connection; nested exception is> > > > redis.clients.jedis.exceptions.JedisConnectionException: Could not get > a> > > > resource from the pool> > > > > > > at> > > > > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch> > > > > JedisConnector(JedisConnectionFactory.java:281)> > > > > > > at> > > > > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.getCo> > > > > nnection(JedisConnectionFactory.java:464)> > > > > > > at> > > > > org.apache.nifi.redis.service.RedisConnectionPoolService.getConnection(Redis> > > > > ConnectionPoolService.java:89)> > > > > > > at sun.reflect.GeneratedMethodAccessor580.invoke(Unknown > Source)> > > > > > > at> > > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > > > > .java:43)> > > > > > > at java.lang.reflect.Method.invoke(Method.java:498)> > > > > > > at> > > > > org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle> > > > > r.invoke(StandardControllerServiceInvocationHandler.java:84)> > > > > > > at com.sun.proxy.$Proxy98.getConnection(Unknown Source)> > > > > > > at> > > > > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.withConn> > > > > ection(RedisDistributedMapCacheClientService.java:343)> > > > > > > at> > > > > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.put(Redi> > > > > sDistributedMapCacheClientService.java:189)> > > > > > > at sun.reflect.GeneratedMethodAccessor579.invoke(Unknown > Source)> > > > > > > at> > > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > > > > .java:43)> > > > > > > at java.lang.reflect.Method.invoke(Method.java:498)> > &g
Re: RedisConnectionPoolService - Incorrectly Attempts to Connect to localhost
FYI I’ve just created a bugreport – I don’t think this is expected behavior. https://issues.apache.org/jira/browse/NIFI-5976 I’ve also described a workaround in there. Cheers Josef From: "Zahner Josef, GSB-LR-TRW-LI" Date: Saturday, 26 January 2019 at 13:07 To: "users@nifi.apache.org" Subject: Re: RedisConnectionPoolService - Incorrectly Attempts to Connect to localhost Hi Jim Did you solve the issue? I have exactly the same behavior… I wanted to try Redis but ended up with this error. Cheers Josef On 2018/11/29 21:54:25, "Williams, Jim" mailto:j...@alertlogic.com>> wrote: > Hello,> > > > > > I'm trying to set up the> > RedisConnectionPoolService/RedisDistributedMapCacheClientService.> > > > > > Some basic observations:> > > * This is a standalone Nifi 1.8.0 server> > * SELinux is disabled on the server> > * There are no iptables rules configured for blocking on the server> > * I am able to resolve the hostname of the Redis server to an IP> > address on the Nifi server> > * I can connect to the Redis server to the Nifi server using telnet> > > > > > The stack trace I see when the services are started is:> > > 2018-11-29 21:16:03,527 WARN [Timer-Driven Process Thread-8]> > o.a.n.controller.tasks.ConnectableTask Administratively Yielding> > PutDistributedMapCache[id=0167105c-4a54-1adf-cb8d-1b45de7f0c99] due to> > uncaught Exception: org.springframework.data.redis.RedisConnection> > > FailureException: Cannot get Jedis connection; nested exception is> > redis.clients.jedis.exceptions.JedisConnectionException: Could not get a> > resource from the pool> > > org.springframework.data.redis.RedisConnectionFailureException: Cannot get> > Jedis connection; nested exception is> > redis.clients.jedis.exceptions.JedisConnectionException: Could not get a> > resource from the pool> > > at> > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch> > JedisConnector(JedisConnectionFactory.java:281)> > > at> > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.getCo> > nnection(JedisConnectionFactory.java:464)> > > at> > org.apache.nifi.redis.service.RedisConnectionPoolService.getConnection(Redis> > ConnectionPoolService.java:89)> > > at sun.reflect.GeneratedMethodAccessor580.invoke(Unknown Source)> > > at> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > .java:43)> > > at java.lang.reflect.Method.invoke(Method.java:498)> > > at> > org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle> > r.invoke(StandardControllerServiceInvocationHandler.java:84)> > > at com.sun.proxy.$Proxy98.getConnection(Unknown Source)> > > at> > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.withConn> > ection(RedisDistributedMapCacheClientService.java:343)> > > at> > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.put(Redi> > sDistributedMapCacheClientService.java:189)> > > at sun.reflect.GeneratedMethodAccessor579.invoke(Unknown Source)> > > at> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > .java:43)> > > at java.lang.reflect.Method.invoke(Method.java:498)> > > at> > org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle> > r.invoke(StandardControllerServiceInvocationHandler.java:84)> > > at com.sun.proxy.$Proxy96.put(Unknown Source)> > > at> > org.apache.nifi.processors.standard.PutDistributedMapCache.onTrigger(PutDist> > ributedMapCache.java:202)> > > at> > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java> > :27)> > > at> > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessor> > Node.java:1165)> > > at> > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java> > :203)> > > at> > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(Timer> > DrivenSchedulingAgent.java:117)> > > at> > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)> > > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)> > > at> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$> > 301(
Re: RedisConnectionPoolService - Incorrectly Attempts to Connect to localhost
Hi Jim Did you solve the issue? I have exactly the same behavior… I wanted to try Redis but ended up with this error. Cheers Josef On 2018/11/29 21:54:25, "Williams, Jim" mailto:j...@alertlogic.com>> wrote: > Hello,> > > > > > I'm trying to set up the> > RedisConnectionPoolService/RedisDistributedMapCacheClientService.> > > > > > Some basic observations:> > > * This is a standalone Nifi 1.8.0 server> > * SELinux is disabled on the server> > * There are no iptables rules configured for blocking on the server> > * I am able to resolve the hostname of the Redis server to an IP> > address on the Nifi server> > * I can connect to the Redis server to the Nifi server using telnet> > > > > > The stack trace I see when the services are started is:> > > 2018-11-29 21:16:03,527 WARN [Timer-Driven Process Thread-8]> > o.a.n.controller.tasks.ConnectableTask Administratively Yielding> > PutDistributedMapCache[id=0167105c-4a54-1adf-cb8d-1b45de7f0c99] due to> > uncaught Exception: org.springframework.data.redis.RedisConnection> > > FailureException: Cannot get Jedis connection; nested exception is> > redis.clients.jedis.exceptions.JedisConnectionException: Could not get a> > resource from the pool> > > org.springframework.data.redis.RedisConnectionFailureException: Cannot get> > Jedis connection; nested exception is> > redis.clients.jedis.exceptions.JedisConnectionException: Could not get a> > resource from the pool> > > at> > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch> > JedisConnector(JedisConnectionFactory.java:281)> > > at> > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.getCo> > nnection(JedisConnectionFactory.java:464)> > > at> > org.apache.nifi.redis.service.RedisConnectionPoolService.getConnection(Redis> > ConnectionPoolService.java:89)> > > at sun.reflect.GeneratedMethodAccessor580.invoke(Unknown Source)> > > at> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > .java:43)> > > at java.lang.reflect.Method.invoke(Method.java:498)> > > at> > org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle> > r.invoke(StandardControllerServiceInvocationHandler.java:84)> > > at com.sun.proxy.$Proxy98.getConnection(Unknown Source)> > > at> > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.withConn> > ection(RedisDistributedMapCacheClientService.java:343)> > > at> > org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.put(Redi> > sDistributedMapCacheClientService.java:189)> > > at sun.reflect.GeneratedMethodAccessor579.invoke(Unknown Source)> > > at> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl> > .java:43)> > > at java.lang.reflect.Method.invoke(Method.java:498)> > > at> > org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle> > r.invoke(StandardControllerServiceInvocationHandler.java:84)> > > at com.sun.proxy.$Proxy96.put(Unknown Source)> > > at> > org.apache.nifi.processors.standard.PutDistributedMapCache.onTrigger(PutDist> > ributedMapCache.java:202)> > > at> > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java> > :27)> > > at> > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessor> > Node.java:1165)> > > at> > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java> > :203)> > > at> > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(Timer> > DrivenSchedulingAgent.java:117)> > > at> > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)> > > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)> > > at> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$> > 301(ScheduledThreadPoolExecutor.java:180)> > > at> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Sch> > eduledThreadPoolExecutor.java:294)> > > at> > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:11> > 49)> > > at> > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:6> > 24)> > > at java.lang.Thread.run(Thread.java:748)> > > Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Could> > not get a resource from the pool> > > at redis.clients.util.Pool.getResource(Pool.java:53)> > > at redis.clients.jedis.JedisPool.getResource(JedisPool.java:226)> > > at redis.clients.jedis.JedisPool.getResource(JedisPool.java:16)> > > at> > org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch> > JedisConnector(JedisConnectionFactory.java:271)> > > ... 26 common frames omitted> > > Caused by: redis.clients.jedis.except
RedisConnectionPoolService - Incorrectly Attempts to Connect to localhost
Hello, I'm trying to set up the RedisConnectionPoolService/RedisDistributedMapCacheClientService. Some basic observations: * This is a standalone Nifi 1.8.0 server * SELinux is disabled on the server * There are no iptables rules configured for blocking on the server * I am able to resolve the hostname of the Redis server to an IP address on the Nifi server * I can connect to the Redis server to the Nifi server using telnet The stack trace I see when the services are started is: 2018-11-29 21:16:03,527 WARN [Timer-Driven Process Thread-8] o.a.n.controller.tasks.ConnectableTask Administratively Yielding PutDistributedMapCache[id=0167105c-4a54-1adf-cb8d-1b45de7f0c99] due to uncaught Exception: org.springframework.data.redis.RedisConnection FailureException: Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool org.springframework.data.redis.RedisConnectionFailureException: Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch JedisConnector(JedisConnectionFactory.java:281) at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.getCo nnection(JedisConnectionFactory.java:464) at org.apache.nifi.redis.service.RedisConnectionPoolService.getConnection(Redis ConnectionPoolService.java:89) at sun.reflect.GeneratedMethodAccessor580.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl .java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle r.invoke(StandardControllerServiceInvocationHandler.java:84) at com.sun.proxy.$Proxy98.getConnection(Unknown Source) at org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.withConn ection(RedisDistributedMapCacheClientService.java:343) at org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.put(Redi sDistributedMapCacheClientService.java:189) at sun.reflect.GeneratedMethodAccessor579.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl .java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandle r.invoke(StandardControllerServiceInvocationHandler.java:84) at com.sun.proxy.$Proxy96.put(Unknown Source) at org.apache.nifi.processors.standard.PutDistributedMapCache.onTrigger(PutDist ributedMapCache.java:202) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java :27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessor Node.java:1165) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java :203) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(Timer DrivenSchedulingAgent.java:117) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$ 301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Sch eduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:11 49) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:6 24) at java.lang.Thread.run(Thread.java:748) Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool at redis.clients.util.Pool.getResource(Pool.java:53) at redis.clients.jedis.JedisPool.getResource(JedisPool.java:226) at redis.clients.jedis.JedisPool.getResource(JedisPool.java:16) at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetch JedisConnector(JedisConnectionFactory.java:271) ... 26 common frames omitted Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused (Connection refused) at redis.clients.jedis.Connection.connect(Connection.java:207) at redis.clients.jedis.BinaryClient.connect(BinaryClient.java:93) at redis.clients.jedis.BinaryJedis.connect(BinaryJedis.java:1767) at redis.clients.jedis.JedisFactory.makeObject(JedisFactory.java:106) at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.jav a:868) at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(
