I have 1400 flowFile with same name and i want to enroll them into one file,
i have read that i can use mergeContent processor for this purpose but when
the amount of flowfile is more than 1 it can't combine them in one file,
what should i change to make this processor work properly? here is
I want to use natural threads for read - write operation in config file , i
have used threads implemented in groovy, but my code neither throws
exception nor makes anything else , here are several subjects i am
interested in:
Is it possible to implement natural Threads inside nifi executeScript
I have one config file inside my nifi environment, in which i should change,
check and update values , but i should make this operation in independent
threads so that(threads should't flush)
here are several things i am interested in:
1. Can i use Synchronized code blocks inside executeScript
I have one config file inside my nifi environment, in which i
should change, check and update values , but i shouldmake this
operation in independent threads so that(threads should't flush)
here are several things i am interested in:
1. Can i use
How to make only one point (Processor or Service) that will write the file
and make it working in single thread, in my case i have workflow like this
executescript1(single thread processor with write
operations)->updateAttribute->InvokeHttpProcessor->executescript1(single
thread processor with
I have one config file which should be processed by several process ( which
will change several parameters in it) i have used filelocks to prevent
working several process on one file at a time but as a result when i try to
start all process at the same time one process (i have 2 process at present
I want to get all flowfile from the queu which fileSize is greater than 831
and then put them into the list after that catch last flowfile from the list
and transfer to success relationship and finally remove all other flowfiles
, here is my code which throws exception that transfer relationship
I want to get all flowfile from the queu which fileSize is greater than 831
and then put them into the list after that catch last flowfile from the list
and transfer to success relationship and finally remove all other flowfiles
, here is my code which throws exception that transfer relationship
Thank you, this post is really helpful
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
Thank you , this post was really helpfull
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
Thank you, this post is really helpfull
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
i want to parse only error ,info, warn data without provinance
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
I want to use nifi logs ( i mean nifi-app.log data) but when i try to get
this files usually i got loads of content on one error and i want to know
how can i filter all this data so that i could get only usefull information
1.should i change some configuration in logback.xml
2.or i should use
I want to get more than 2 flowfile from hdfs and reunit them into one
flowfile ( i mean i want to get data from these files (they are in xml
format) and input it into variable named content ,then when i finish this
process i want to serilize xml in a way that all this data will be enrolled
I want to romeve namespaces from my xml response(now i am working inside nifi
environment,so i have to use groovy utilities) here is my code , but it
throws FlowfFileHandlingException, what should i change to make this code
work?:
import org.apache.commons.io.IOUtils
import
I want to add xml tag ${filename} to xml response which i got from service
how should i do it i mean i have made replace, end even delet operations in
replaceText processor but how can i add something?
1.Should i use Replace Text processor i should do it with groovy code?(p.s i
should add this
Yes , but when i add this static import i can't run maven
project ( it doesn't support static imports)
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
I want to use getFileSytem() for pulling in any file that is newer than the
timestamp that we have but I can't import it (I mean getFileSytem()) I have
this code:
final FileSystem hdfs = getFileSystem();
final boolean recursive = context.getProperty(RECURSE_SUBDIRS).asBoolean();
final Set
I want to get real name of file from one previous flowfile and then match how
many flowfile with this name exists in certain directory , here is my code
but it trows exception which tells that startup failed because unexpected
char 0X, here is my code what should i change?
*how should i
I have several flowfiles in sucess queue in which i have parameter count and
i have to transfer only counter amount flowfiles , every time counter value
is different so any time i will have to get it from flowfile( all flowfile
from this success queue have this attribute), i have tried this logic
I want to get one flowFile (from success queue) to read count attribute from
it, and then i want to get count number flowfiles and put it in flowfile
List after that i will check if flowfile list size == count i will transfer
all receveied flowfiles I have tried codes like this, but this logic
i have service which will send amount of possible response in tag cold count
( i mean it have paging implemented inside it ) but i want to be sure that
every time i make request i will get certain amount of response i mean if i
send request and in first respone tag value is 3 in best case i will
22 matches
Mail list logo
