I changed my mind. 1.GenerateFlowFile (Triger)→ 2.ExecuteScript (groovy) → 3.EvaluateJsonPath → 4.ExecuteSQL ExecuteScript content is below def flowFile = session.get() if(!flowFile) return // Executescript attributes def serviceName = dbcp.value def sqlCmdString = sqlCmd.value def jsonSlurper = new JsonSlurper() // get controller service lookup from context def lookup = context.controllerServiceLookup // search for serviceName in controller services def dbcpServiceId = lookup.getControllerServiceIdentifiers(ControllerService).find {     cs -> lookup.getControllerServiceName(cs) == serviceName } //Get the service from serviceid def service = lookup.getControllerService(dbcpServiceId) // Connect to service def conn = service.getConnection() if (!conn) {   log.error("Failed to connect to " + serviceName)   return; } try { //flowFile = session.create() flowFile = session.write(flowFile, {out -> def sql = new Sql(conn)   if (!sql) {     log.error("Failed to get SQL connection")     return   } //def sqlCmdString = "ExecuteScript Attributs info" def rows = sql.rows(sqlCmdString) """     i want to know the part that decompresses select return value and transfers json file to lower flow file. """ } as OutputStreamCallback) session.transfer(flowFile, REL_SUCCESS) } catch(e) {     conn?.close()     log.error("Scripting error " + sqlCmd, e)     session.transfer(flowFile, REL_FAILURE) } // Release connection, this is important as it will otherwise block new executions conn?.close() ... View more