@Chen Yimu Did the answer help in the resolution of your query? Please close the thread by marking the answer as Accepted! ... View more

The relevant part of the log is "Address already in use", looks like you've configured ListenHttp to listen on port 8081 but some other process is using that port already. ... View more

@Matt Burgess It works fine if there is just one object in the input tree if there are more it makes them as an array rather than separate records. Like {   "agent_submit_time" : [ -1, -1 ],   "agent_end_time" : [ 123445, 123445 ],   "agent_name" : [ "Marie Bayer-Smith", "Marie Bayer-Smith" ] } I would like to to be something like [ { "agent_submit_time" : -1, "agent_end_time" : 123445, "agent_name" : "Marie Bayer-Smith" }, { "agent_submit_time" : -1, "agent_end_time" : 123445, "agent_name" : "Marie Bayer-Smith" } ] How to do that. I tried but I couldnt replaceing "*": "&" with "@": "[&]" makes it separate but the transformation of - to _ doesnt takes place. ... View more

Native through the standard Hadoop Java client. ... View more

My file extension is avro i can't use def schema = ff.read().withReader("UTF-8"){newJsonSlurper().parse(it)} I have to use each and then parse schema. Do you an example plz @Matt Burgess ... View more

Thanks for replying @Abdelkrim Hadjidj @Matt Burgess. Now I have two different schemas for input and output CSV for LookupRecord. I modified Result RecordPath to /COMPANY. When I start LookupRecord it takes in 6 flow files but doesn't return anything. ... View more

Hi @@dhieru singh Thank you for the post , but I am unable to get the values of $.component.backPressureObjectThreshold $.status.aggregateSnapshot.flowFilesQueued after processing the EvaluateJsonPath. ... View more

The process group name can actually be found with the attached groovy code: def flowFile = session.get() if(!flowFile) return processGroupName = context.procNode?.getProcessGroup().getName() flowFile = session.putAttribute(flowFile, 'processGroupName', processGroupName) session.transfer(flowFile, REL_SUCCESS) ... View more

@Anil Reddy In addition to Matt's answer if you want to know all supported Functions in Expression Language for your version of NiFi then click on Right Up Corner GlobalMenu Button And click on Help 3.Then Click on Expression Language Guide on Right Side will shows up all the functions that are supported in your version of NiFi. If you want to implement ${closed_epoch:format("yyyy", "GMT")} this expression even though it is not supported in your version of NiFi then as a work around you can use plus,minus functions. Assuming your closed_epoch attribute value is 1453843201123 ${closed_epoch:minus(86400000)} //this expression will minus 86,400,000 Milliseconds(i.e 24 hrs) from closed_epoch value. New value for closed_epoch will be 1453756801123. *if you are having DayLightSaving time then you need to change the milliseconds value in minus(or) plus function. ... View more

Schema schema = .... @SuppressWarnings("static-access") Decoder binaryDecoder = DecoderFactory.get().get().binaryDecoder(value.toString().getBytes(), null); System.out.println("test"); @SuppressWarnings("rawtypes") GenericDatumReader<GenericRecord> payloadReader = new SpecificDatumReader<GenericRecord>(schema); System.out.println("test1" + binaryDecoder.toString().length()+ "test"); GenericRecord recode = null; recode = payloadReader.read(recode, binaryDecoder); System.out.println("test2"); ... View more