Looks as though the cache was never started and it was then not possible to connect to it. Are there other errors when the flow initializes concerning the cache's initialization?
On Mon, Oct 16, 2017 at 8:23 AM, rakesh <[email protected]> wrote: > Hi Aldrin, > > Thanks for your help. The error reported is goneaway after I removed the > client cache jar file however I am getting following error. > > 2017-10-16 16:13:30,543 ERROR [Timer-Driven Process Thread-2] > o.a.n.c.m.processors.CaptureChangeMySQL > CaptureChangeMySQL[id=ec3e8c52-1f98-3a38-0000-000000000000] Failed to > process session due to org.apache.nifi.processor. > exception.ProcessException: > java.io.IOException: Could not connect to Distributed Map Cache server to > get table information: {} > org.apache.nifi.processor.exception.ProcessException: java.io.IOException: > Could not connect to Distributed Map Cache server to get table information > at > org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL. > onTrigger(CaptureChangeMySQL.java:593) > at > org.apache.nifi.controller.StandardProcessorNode.onTrigger( > StandardProcessorNode.java:1118) > at > org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call( > ContinuallyRunProcessorTask.java:144) > at > org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call( > ContinuallyRunProcessorTask.java:47) > at > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run( > TimerDrivenSchedulingAgent.java:132) > at java.util.concurrent.Executors$RunnableAdapter.call(Unknown > Source) > at java.util.concurrent.FutureTask.runAndReset(Unknown Source) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ > ScheduledFutureTask.access$301(Unknown > Source) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run( > Unknown > Source) > at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown > Source) > at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown > Source) > at java.lang.Thread.run(Unknown Source) > Caused by: java.io.IOException: Could not connect to Distributed Map Cache > server to get table information > at > org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL.outputEvents( > CaptureChangeMySQL.java:742) > at > org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL. > onTrigger(CaptureChangeMySQL.java:571) > ... 11 common frames omitted > Caused by: java.net.ConnectException: Connection refused: connect > at sun.nio.ch.Net.connect0(Native Method) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) > at java.nio.channels.SocketChannel.open(Unknown Source) > at > org.apache.nifi.distributed.cache.client.StandardCommsSession.<init>( > StandardCommsSession.java:51) > at > org.apache.nifi.distributed.cache.client.DistributedMapCacheClientServi > ce.createCommsSession(DistributedMapCacheClientService.java:300) > at > org.apache.nifi.distributed.cache.client.DistributedMapCacheClientServi > ce.leaseCommsSession(DistributedMapCacheClientService.java:315) > at > org.apache.nifi.distributed.cache.client.DistributedMapCacheClientServi > ce.withCommsSession(DistributedMapCacheClientService.java:370) > at > org.apache.nifi.distributed.cache.client.DistributedMapCacheClientServi > ce.get(DistributedMapCacheClientService.java:184) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) > at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) > at java.lang.reflect.Method.invoke(Unknown Source) > at > org.apache.nifi.controller.service.StandardControllerServiceInvoc > ationHandler.invoke(StandardControllerServiceInvocationHandler.java:89) > at com.sun.proxy.$Proxy23.get(Unknown Source) > at > org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL.outputEvents( > CaptureChangeMySQL.java:740) > ... 12 common frames omitted > > > Here with I'm attaching my config.yml of MiNiFi. config.yml > <http://apache-nifi-users-list.2361937.n4.nabble.com/file/t310/config.yml> > Kindly help us to resolve this. > > > Thanks > Rakesh. > > > > -- > Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/ >
