[ https://issues.apache.org/jira/browse/NIFI-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158821#comment-16158821 ]
Daniel edited comment on NIFI-4260 at 9/8/17 4:17 PM: ------------------------------------------------------ can you please upload the modified *nifi-flume-nar-1.3.0.nar *and the *nifi-flume-nar-1.2.0.3.0.1.0-43.nar *as a quick-fix for us? was (Author: dash42): can you please upload the modified nifi-flume-nar-1.3.0.nar as a quick-fix for us? > ExecuteFlumeSink not working with Sink Type "avro". > --------------------------------------------------- > > Key: NIFI-4260 > URL: https://issues.apache.org/jira/browse/NIFI-4260 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions > Affects Versions: 1.2.0, 1.3.0 > Reporter: Sebastian Schlitte > > After upgrading NiFi from 1.1.2 to 1.2.0, ExecuteFlumeSink with sink type > "avro" stops transmitting data and throws the error quoted below. The problem > persists after upgrading to 1.3.0. > Replacing avro-ipc-1.7.4.jar with avro-ipc-1.8.1.jar in > nifi-flume-nar-1.3.0.nar solves the issue. > {{2017-08-02 10:28:51,142 ERROR [Timer-Driven Process Thread-6] > o.a.n.processors.flume.ExecuteFlumeSink > ExecuteFlumeSink[id=98da368f-015d-1000-ffff-ffff9 > 6768472] ExecuteFlumeSink[id=98da368f-015d-1000-ffff-ffff96768472] failed to > process due to org.apache.nifi.processor.exception.ProcessException: Flume > event delivery failed; rolling back session: {} > org.apache.nifi.processor.exception.ProcessException: Flume event delivery > failed > at > org.apache.nifi.processors.flume.ExecuteFlumeSink.onTrigger(ExecuteFlumeSink.java:145) > at > org.apache.nifi.processors.flume.AbstractFlumeProcessor.onTrigger(AbstractFlumeProcessor.java:148) > 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(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:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:748) > Caused by: org.apache.flume.EventDeliveryException: Failed to send events > at > org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:392) > at > org.apache.nifi.processors.flume.ExecuteFlumeSink.onTrigger(ExecuteFlumeSink.java:143) > ... 12 common frames omitted > Caused by: org.apache.flume.EventDeliveryException: NettyAvroRpcClient { > host: target.linux.dummy, port: 14100 }: Failed to send batch > at > org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:315) > at > org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:376) > ... 13 common frames omitted > Caused by: org.apache.flume.EventDeliveryException: NettyAvroRpcClient { > host: target.linux.dummy, port: 14100 }: RPC request exception > at > org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:365) > at > org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:303) > ... 14 common frames omitted > Caused by: java.util.concurrent.ExecutionException: > java.lang.AbstractMethodError: > org.apache.avro.specific.SpecificFixed.getSchema()Lorg/apache/avro/S > chema; > at java.util.concurrent.FutureTask.report(FutureTask.java:122) > at java.util.concurrent.FutureTask.get(FutureTask.java:206) > at > org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:357) > ... 15 common frames omitted > Caused by: java.lang.AbstractMethodError: > org.apache.avro.specific.SpecificFixed.getSchema()Lorg/apache/avro/Schema; > at > org.apache.avro.specific.SpecificFixed.<init>(SpecificFixed.java:36) > at org.apache.avro.ipc.MD5.<init>(MD5.java:16) > at org.apache.avro.ipc.Requestor.writeHandshake(Requestor.java:200) > at org.apache.avro.ipc.Requestor.access$300(Requestor.java:52) > at org.apache.avro.ipc.Requestor$Request.getBytes(Requestor.java:478) > at org.apache.avro.ipc.Requestor.request(Requestor.java:147) > at org.apache.avro.ipc.Requestor.request(Requestor.java:129) > at > org.apache.avro.ipc.specific.SpecificRequestor.invoke(SpecificRequestor.java:84) > at com.sun.proxy.$Proxy124.appendBatch(Unknown Source) > at > org.apache.flume.api.NettyAvroRpcClient$2.call(NettyAvroRpcClient.java:348) > at > org.apache.flume.api.NettyAvroRpcClient$2.call(NettyAvroRpcClient.java:344) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > ... 3 common frames omitted}} -- This message was sent by Atlassian JIRA (v6.4.14#64029)