@kcc, as this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. ... View more

Agreed, you do not have access to the fields in either the incoming or outgoing JSON objects using Expression Language in the spec. ... View more

I believe the type checking for logical types is more strict now as of https://issues.apache.org/jira/browse/AVRO-2493 and NiFi 1.17.0 (when we upgraded to Avro 1.11.1). Are you using "int" or "string" as the normal Avro type? According the spec (https://avro.apache.org/docs/1.11.1/specification/#timestamp-millisecond-precision) it must be "long". ... View more

Try specifying schema with precision ex: {"type":"record","name":"schema","fields":[{"name":"_COL_0","type":{"type":"fixed","name":"_COL_0","size":16,"logicalType":"decimal","precision":38,"scale":0}}} ... View more

@Althotta As this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. Thanks! ... View more

@yamaga, as this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. ... View more

@rafy, as this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. ... View more

@krishna123 as this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. ... View more

Ah I'm so careless, thanks for pointing that out! ... View more

@mburgess .. Hope you are doing good. I am facing issue while creating a groovy script for Scripted Reader Controller service in Convert Record processor. I want read the Flat width file input but script validation is getting failed again and again. It is giving 'groovy.lang.MissingPropertyException: No such property: session for class: Script'   My code is below (also not sure my logic is correct for reading the Fixed Width File as input) Please let me know what's the issue here.    import org.apache.commons.io.IOUtils import java.nio.charset.StandardCharsets import java.nio.charset.UnsupportedCharsetException; import java.io.IOException; import org.apache.nifi.controller.ControllerService flowFile = session.get() if(!flowFile) return try { def text = '' // Cast a closure with an inputStream parameter to InputStreamCallback session.read(flowFile, {inputStream -> def readIN = IOUtils.toString(inputStream, StandardCharsets.UTF_8) names = [] text = readIN.eachLine { names << [ data: it[0..7].trim(), name: it[8..33].trim(), isr: it[34..43].trim() ]} readIN.close() } as InputStreamCallback) session.transfer(flowFile, REL_SUCESS) } catch(e) { log.error("Error while processing the flowfile") session.transfer(flowFile, REL_FAILURE) } ... View more