Sebastian Schlitte created NIFI-4260:
----------------------------------------
Summary: 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.3.0, 1.2.0
Reporter: Sebastian Schlitte
Priority: Minor
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)
