nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rakesh <rakesh999.a...@gmail.com>
Subject Re: Capture Change Mysql Processor is unable to start using minifi
Date Mon, 16 Oct 2017 12:23:45 GMT
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.DistributedMapCacheClientService.createCommsSession(DistributedMapCacheClientService.java:300)
	at
org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService.leaseCommsSession(DistributedMapCacheClientService.java:315)
	at
org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService.withCommsSession(DistributedMapCacheClientService.java:370)
	at
org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService.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.StandardControllerServiceInvocationHandler.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/

Mime
View raw message