Support Questions

Find answers, ask questions, and share your expertise

Problems with flow after adding replacetext processor

New Contributor

Replciating data from ORacle => Couchabse fine.


I add a replacetextprocessor after the query (Literla text replace) and now errors


2019-06-06 20:36:46,516 WARN [Timer-Driven Process Thread-3] o.a.n.controller.tasks.ConnectableTask Administratively Yielding SplitAvro[id=241d3e17-016b-1000-68f3-2a34dba86e4f] due to uncaught Exception: java.lang.IllegalArgumentException java.lang.IllegalArgumentException: null at java.nio.ByteBuffer.allocate( at at org.apache.avro.file.DataFileStream.initialize( at org.apache.avro.file.DataFileStream.( at org.apache.nifi.processors.avro.SplitAvro$RecordSplitter$1.process( at at at org.apache.nifi.processors.avro.SplitAvro$RecordSplitter.split( at org.apache.nifi.processors.avro.SplitAvro.onTrigger( at org.apache.nifi.processor.AbstractProcessor.onTrigger( at org.apache.nifi.controller.StandardProcessorNode.onTrigger( at org.apache.nifi.controller.tasks.ConnectableTask.invoke( at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$ at org.apache.nifi.engine.FlowEngine$ at java.util.concurrent.Executors$ at java.util.concurrent.FutureTask.runAndReset( at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301( at java.util.concurrent.ScheduledThreadPoolExecutor$ at java.util.concurrent.ThreadPoolExecutor.runWorker( at java.util.concurrent.ThreadPoolExecutor$ at


Your syntax in replace text is invalid, resulting in the next error in the Avro Processor.
Confirm your syntax is operational. Another recommendation is stop Avro, and inspect the FlowFile and Attributes are what you expect before trying play through to the Avro Processor.

New Contributor

Hi @steven Matison

My textreplace processor is pretty simple (literal).


(I've tried with and without quotes).

It passes this processor ok and actually fails on an existing processor (unchanged) for SplitArvo


New Contributor

So I replaced this with a flow that goes .....

Works perfect.

Still confused on when to use which processors

i.e I used ConvertArvotoJson only because I wanted JSON format. Was looking for a SQLtoJSOON - but doesnt exist.

So quesitons

1) arvo/binary/text processors - how do you know if you need to convert between two main processors ? Based on format etc. eg When it comes out of the querydatabasetable => what format is it in ?

2) How do you do a bulk load - and then an incremental sync from a DB or a file.