Hi
I'm using many RedisDistributedMapCacheClientService and
some RedisConnectionPoolService which connect to my 3 node cluster
with Redis sentinels.
If I run the same configuration at a NIFI v. 1.13.2 everything works. If I
create the same configuration on v. 1.14.0 I gets the error below:
2021-08-05 13:24:12,556 WARN [Timer-Driven Process Thread-3]
o.a.n.controller.tasks.ConnectableTask Administratively Yielding
DetectDuplicate[id=feb1f2ff-4f9c-31d7-87c8-e225a80ef03f] due to uncaught
Exception: redis.clients.jedis.exceptions.JedisConnectionException: All
sentinels down, cannot determine where is mymaster master is running...
redis.clients.jedis.exceptions.JedisConnectionException: All sentinels
down, cannot determine where is mymaster master is running...
at
redis.clients.jedis.JedisSentinelPool.initSentinels(JedisSentinelPool.java:281)
at
redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:205)
at
redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:193)
at
org.springframework.data.redis.connection.jedis.JedisConnectionFactory.createRedisSentinelPool(JedisConnectionFactory.java:411)
at
org.springframework.data.redis.connection.jedis.JedisConnectionFactory.createPool(JedisConnectionFactory.java:393)
at
org.springframework.data.redis.connection.jedis.JedisConnectionFactory.afterPropertiesSet(JedisConnectionFactory.java:348)
at
org.apache.nifi.redis.util.RedisUtils.createConnectionFactory(RedisUtils.java:342)
at
org.apache.nifi.redis.service.RedisConnectionPoolService.getConnection(RedisConnectionPoolService.java:92)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:254)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:105)
at com.sun.proxy.$Proxy181.getConnection(Unknown Source)
at
org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.withConnection(RedisDistributedMapCacheClientService.java:375)
at
org.apache.nifi.redis.service.RedisDistributedMapCacheClientService.getAndPutIfAbsent(RedisDistributedMapCacheClientService.java:144)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:254)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:105)
at com.sun.proxy.$Proxy179.getAndPutIfAbsent(Unknown Source)
at
org.apache.nifi.processors.standard.DetectDuplicate.onTrigger(DetectDuplicate.java:183)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1202)
at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:214)
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:103)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
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(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
I know the WARN says: All sentinels down, cannot determine where is
mymaster master is running... BUT It is not. The Sentinel master is
running, I have a 2nd NIFI server running with v. 1.13.2 which is using the
same Redis cluster ait that one is still working.
A new feature in v.1.14.0 is the property "SSL Context
Service" RedisConnectionPoolService. It says if configured it will use ssl
to etablish a secure connection, if not configured til will not be secure.
It is not configured.
Please any help :-)
kind regards
Jens M. Kofoed
