Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Problems with flow after adding replacetext processor

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


Re: Problems with flow after adding replacetext processor

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.



If this answer resolves your issue or allows you to move forward, please choose to ACCEPT this solution and close this topic. If you have further dialogue on this topic please comment here or feel free to private message me. If you have new questions related to your Use Case please create separate topic and feel free to tag me in your post.  





Re: Problems with flow after adding replacetext 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



Re: Problems with flow after adding replacetext processor

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.

Don't have an account?
Coming from Hortonworks? Activate your account here