nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aldrin Piri <aldrinp...@gmail.com>
Subject Re: Capture Change Mysql Processor is unable to start using minifi
Date Mon, 16 Oct 2017 13:19:22 GMT
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 <rakesh999.alla@gmail.com> 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/
>

Mime
View raw message