Hello, I'm using the processor inferAvroSchema to infer the schema table from a csv. I want to use the GetAvroMetadata processor to extract the record name from the results of inferAvroSchema but I don't know how to configure the processor. I know that I can use a groovy code to extract the record name but I think GetAvroMetadata is used for this purpose too. capture.png Can someone help me plz. Thank you ... View more

Hello, My dataflow is as follow: My purpose is to create a table from a csv file and then put the data in this table. Everything is working good but I need to check if the table is created before storing the csv file. So I used the Execute SQL to run this query: select count(table_name) from information_schema.tables where table_name='warranty' But it returns only the number of rows and not the flowfile. My test is if number of row is one so I execute the rest. So I need to use dataflow which can check if the table is well created and execute the other processors if not it stop every thing. Can you help me plz I know that i can find another way but don't find ideas. Thank you for your help. ... View more

Hello, The header of my csv file contains some special character. Example Name,T&C_Test,Date_of_(Transformation) And I want to use the processor Replace Text to edit only the header. When I use the Append Stratesy for the entire text, it dosen't work. Help plz. Thank you ... View more

Hello, I inquired about the directory of templates nifi before asking the question. And I saw that all templates are stored in flow.xml.gz. My question is can I opt for a directory that stores the templates instead of this file. Is it more correct and will not cause problems. Thank you ... View more

Hello, when I run a nifi stream with a misconfigured processor. At first I have this error: 502 Unexpected Response. When I do a reload of the page I have 502 Bad Gateway. Should I change something in the nifi config to avoid this problem. Thank you ... View more

Hello, I want to be able to send automatically generated data with random from python to nifi using the requests library. on the nifi side I intend to use gethttp to retrieve the data. My question: what should I put in the URL parameter? I do not understand much t the APIs I searched on the internet since this morning but it remains a little vague someone can help me? thank you ... View more

Hello, I have a CSV file that I want to insert into a table. Sometimes I have string columns to insert in long columns that pose a normal problem. I'm looking for a way to put those lines aside ( in a flowfile ) and insert the rest. I'm using the putDatabaseRecord processor to insert the csv file. Thank you ... View more

I'm using groovy in Execute processor to read an avro schema to create a sql table. My code is : import groovy.json.JsonSlurper def ff = session.get() if(!ff)return def schema = ff.read().withReader("UTF-8"){ new JsonSlurper().parse(it) } def typeMap = [ "string" : "varchar(255)", "long" : "numeric(10)", [ "null", "string" ]: "varchar(255)", [ "null", "long" ] : "numeric(10)", ] def createTable = "create table ${schema.name} (" + schema.fields.collect{ "\n ${it.name.padRight(39)} ${typeMap[it.type]}" }.join(',') + "\n)" SQL.mydb.execute(createTable) REL_SUCCESS << ff And I got this error can someone help me plz ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.script.ExecuteScript ExecuteScript[id=e65b733e-0161-1000-45f0-3264d6fb51dd] ExecuteSc$ Possible solutions: getId(), find(), grep(), each(groovy.lang.Closure), find(groovy.lang.Closure), grep(java.lang.Object); rolling back session: {} org.apache.nifi.processor.exception.ProcessException: javax.script.ScriptException: javax.script.ScriptException: groovy.lang.MissingMethodException: No signature of m$ Possible solutions: getId(), find(), grep(), each(groovy.lang.Closure), find(groovy.lang.Closure), grep(java.lang.Object) at org.apache.nifi.processors.script.ExecuteScript.onTrigger(ExecuteScript.java:230) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1119) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) 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:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: javax.script.ScriptException: javax.script.ScriptException: groovy.lang.MissingMethodException: No signature of method: org.apache.nifi.controller.repositor$ Possible solutions: getId(), find(), grep(), each(groovy.lang.Closure), find(groovy.lang.Closure), grep(java.lang.Object) ... View more

Hello, Using InferAvroSchema I got an avro Schema of my file. I want to create at able in PostregSql using this avroSchema. Which processor I have to use and connect to InferAvroSchema to create my table. Thank you! ... View more