Hi I'm trying to create custom processor where 'Scheduling tab' is disabled/removed, or cant be modified. how to achieve this? Thanks 97493-screenshot-2018-12-31-at-115327.png ... View more

Hi I'm trying to create custom processor where Scheduling tab is disabled, or cant be modified. is this possible ? Thanks ... View more

Hi I'm trying to enable versioning on NIFI, I managed to create local certificate and linked Nifi to Nifi registry. I'm still getting the below error, can you help ? what should I change Unable to obtain listing of buckets: org.apache.nifi.registry.client.NiFiRegistryException: Error retrieving all buckets: Untrusted proxy [CN=localhost, OU=NIFI]. Contact the system administrator. Thanks ... View more

Hi I created custom processor which query mongoDB, I used connectionPool to manage connections. However, closeClient() function is not triggered when I stop or shutdown the custom processor. can you advise what should I change ? @OnStopped @OnShutdown @OnRemoved public final void closeClient() { if (mongoClient != null) { getLogger().error("Closing MongoClient"); mongoClient.close(); mongoClient = null; } } My processor code /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package nifi.processors.nifi; import com.mongodb.MongoClient; import com.mongodb.MongoClientURI; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.nio.charset.StandardCharsets; import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.flowfile.FlowFile; import org.apache.nifi.annotation.behavior.ReadsAttribute; import org.apache.nifi.annotation.behavior.ReadsAttributes; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.documentation.CapabilityDescription; import org.apache.nifi.annotation.documentation.SeeAlso; import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.AbstractProcessor; import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessSession; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processor.Relationship; import org.apache.nifi.processor.util.StandardValidators; import java.util.ArrayList; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; import java.io.OutputStreamWriter; import org.apache.nifi.annotation.lifecycle.OnRemoved; import org.apache.nifi.annotation.lifecycle.OnShutdown; import org.apache.nifi.annotation.lifecycle.OnStopped; import org.apache.nifi.logging.ComponentLog; import org.apache.nifi.mongodb.MongoDBClientService; import org.apache.nifi.processor.exception.FlowFileAccessException; import org.bson.Document; @Tags({"example"}) @CapabilityDescription("Provide a description") @SeeAlso({}) @ReadsAttributes({ @ReadsAttribute(attribute = "", description = "")}) @WritesAttributes({ @WritesAttribute(attribute = "", description = "")}) public class MyProcessor extends AbstractProcessor { public static final PropertyDescriptor MY_PROPERTY = new PropertyDescriptor.Builder().name("MY_PROPERTY") .displayName("Prefix property") .description("Prefix Property") .required(true) .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); static final PropertyDescriptor CLIENT_SERVICE = new PropertyDescriptor.Builder() .name("mongo-client-service") .displayName("Client Service") .description("If configured, this property will use the assigned client service for connection pooling.") .required(true) .identifiesControllerService(MongoDBClientService.class) .build(); public static final Relationship REL_SUCCESS = new Relationship.Builder() .name("Success") .description("Sucessful relationship") .build(); public static final Relationship REL_FAILURE = new Relationship.Builder() .name("Fail") .description("Failure relationship") .build(); private List<PropertyDescriptor> descriptors; private Set<Relationship> relationships; @Override protected void init(final ProcessorInitializationContext context) { final List<PropertyDescriptor> descriptors = new ArrayList<PropertyDescriptor>(); descriptors.add(MY_PROPERTY); descriptors.add(CLIENT_SERVICE); this.descriptors = Collections.unmodifiableList(descriptors); final Set<Relationship> relationships = new HashSet<Relationship>(); relationships.add(REL_SUCCESS); relationships.add(REL_FAILURE); this.relationships = Collections.unmodifiableSet(relationships); } @Override public Set<Relationship> getRelationships() { return this.relationships; } @Override public final List<PropertyDescriptor> getSupportedPropertyDescriptors() { return descriptors; } protected MongoClient mongoClient; protected MongoDBClientService clientService; @OnScheduled public void onScheduled(final ProcessContext context) { clientService = context.getProperty(CLIENT_SERVICE).asControllerService(MongoDBClientService.class); if (mongoClient != null) { closeClient(); } mongoClient = new MongoClient(new MongoClientURI(clientService.getURI())); } @OnStopped @OnShutdown @OnRemoved public final void closeClient() { if (mongoClient != null) { getLogger().error("Closing MongoClient"); mongoClient.close(); mongoClient = null; } } @Override public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { FlowFile flowFile = session.get(); if (flowFile == null) { return; } final ComponentLog logger = getLogger(); final String prefixStr = context.getProperty(MY_PROPERTY).getValue(); try { flowFile = session.write(flowFile, (final InputStream inputStream, final OutputStream outputStream) -> { BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream, StandardCharsets.UTF_8)); String line; while ((line = bufferedReader.readLine()) != null) { String xxx = mongoDB( prefixStr, line); String aggregatedText = prefixStr + ": " + line + ": " + xxx; bufferedWriter.write(aggregatedText); bufferedWriter.newLine(); } bufferedWriter.flush(); }); session.transfer(flowFile, REL_SUCCESS); logger.info("successfully processed FlowFile {}", new Object[]{flowFile}); } catch (FlowFileAccessException e) { session.transfer(flowFile, REL_FAILURE); logger.info("Failed to add prefix for FlowFile: " + e.getMessage()); } } String db_name = "cms", host_name = "localhost"; MongoDatabase db = mongoClient.getDatabase(db_name); public String mongoDB(String arg1, String arg2) { final ComponentLog logger = getLogger(); String result = ""; try { String db_col_name = arg1; MongoCollection<Document> coll = db.getCollection(db_col_name); Document query = new Document(); query.put("msisdn", arg2); logger.info(query.toJson()); FindIterable<Document> fi = coll.find(query); try (MongoCursor<Document> cursor = fi.iterator()) { while (cursor.hasNext()) { result = result + cursor.next().toJson(); } } } catch (Exception e) { logger.info("Error: " + e.getMessage()); } return result; } } ... View more

Hi. I have made a simple nifi GetMongo flow using MongoDBControllerService in order to manage connections. When I stop the GetMongo process or even delete it completely, conection to MongoDB is not closed, can you advise where I messed up ? Thanks ... View more

Hi. I have made a simple nifi GetMongo flow using MongoDBControllerService in order to manage connections. When I stop the GetMongo process or even delete it completely, conection to MongoDB is not closed, can you advise where I messed up ? Thanks ... View more

Below is my custom processor which selects data from mongoDB and write it in flowFile stream. Code is working fine but I need to modify the connection part so it uses connection pool instead of traditional connection. Similar to GetMongo processor String db_name = "cms", host_name = "localhost"; MongoClient mongo_client = new MongoClient(host_name, 27017); MongoDatabase db = mongo_client.getDatabase(db_name); How to achieve this, Custom processor Below /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package test.processors.test2; import com.mongodb.MongoClient; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.nio.charset.StandardCharsets; import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.flowfile.FlowFile; import org.apache.nifi.annotation.behavior.ReadsAttribute; import org.apache.nifi.annotation.behavior.ReadsAttributes; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.documentation.CapabilityDescription; import org.apache.nifi.annotation.documentation.SeeAlso; import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.AbstractProcessor; import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessSession; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processor.Relationship; import org.apache.nifi.processor.util.StandardValidators; import java.util.ArrayList; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; import java.io.OutputStreamWriter; import org.apache.nifi.logging.ComponentLog; import org.apache.nifi.processor.exception.FlowFileAccessException; import org.bson.Document; @Tags({"example"}) @CapabilityDescription("Provide a description") @SeeAlso({}) @ReadsAttributes({ @ReadsAttribute(attribute = "", description = "")}) @WritesAttributes({ @WritesAttribute(attribute = "", description = "")}) public class MyProcessor extends AbstractProcessor { public static final PropertyDescriptor MY_PROPERTY = new PropertyDescriptor.Builder().name("MY_PROPERTY") .displayName("Prefix property") .description("Prefix Property") .required(true) .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final Relationship REL_SUCCESS = new Relationship.Builder() .name("Success") .description("Sucessful relationship") .build(); public static final Relationship REL_FAILURE = new Relationship.Builder() .name("Fail") .description("Failure relationship") .build(); private List<PropertyDescriptor> descriptors; private Set<Relationship> relationships; @Override protected void init(final ProcessorInitializationContext context) { final List<PropertyDescriptor> descriptors = new ArrayList<PropertyDescriptor>(); descriptors.add(MY_PROPERTY); this.descriptors = Collections.unmodifiableList(descriptors); final Set<Relationship> relationships = new HashSet<Relationship>(); relationships.add(REL_SUCCESS); relationships.add(REL_FAILURE); this.relationships = Collections.unmodifiableSet(relationships); } @Override public Set<Relationship> getRelationships() { return this.relationships; } @Override public final List<PropertyDescriptor> getSupportedPropertyDescriptors() { return descriptors; } @OnScheduled public void onScheduled(final ProcessContext context) { } @Override public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { FlowFile flowFile = session.get(); if (flowFile == null) { return; } final ComponentLog logger = getLogger(); final String prefixStr = context.getProperty(MY_PROPERTY).getValue(); try { flowFile = session.write(flowFile, (final InputStream inputStream, final OutputStream outputStream) -> { BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream, StandardCharsets.UTF_8)); String line; while ((line = bufferedReader.readLine()) != null) { String xxx = mongoDB( prefixStr, line); String aggregatedText = prefixStr + ": " + line + ": " + xxx; bufferedWriter.write(aggregatedText); bufferedWriter.newLine(); } bufferedWriter.flush(); }); session.transfer(flowFile, REL_SUCCESS); logger.info("successfully processed FlowFile {}", new Object[]{flowFile}); } catch (FlowFileAccessException e) { session.transfer(flowFile, REL_FAILURE); logger.info("Failed to add prefix for FlowFile: " + e.getMessage()); } } String db_name = "cms", host_name = "localhost"; MongoClient mongo_client = new MongoClient(host_name, 27017); MongoDatabase db = mongo_client.getDatabase(db_name); public String mongoDB(String arg1, String arg2) { final ComponentLog logger = getLogger(); String result = ""; try { String db_col_name = arg1; MongoCollection<Document> coll = db.getCollection(db_col_name); Document query = new Document(); query.put("msisdn", arg2); logger.info(query.toJson()); FindIterable<Document> fi = coll.find(query); try (MongoCursor<Document> cursor = fi.iterator()) { while (cursor.hasNext()) { result = result + cursor.next().toJson(); } } } catch (Exception e) { logger.info("Error: " + e.getMessage()); } return result; } } ... View more

Hi All, I'm trying to create simple custom processor, I used to work with executeScript processor to for loop using the below flowFile = session.write(flowFile, {inputStream, outputStream -> inputStream.eachLine { line -> def a = line.split("\\|", -1) outputStream.write("$Test ABCABC\n".toString().getBytes(StandardCharsets.UTF_8)) } } as StreamCallback) How can I rewrite this in Java, to inject in the below custom processor code /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package hwx.processors.hwx; import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.flowfile.FlowFile; import org.apache.nifi.annotation.behavior.ReadsAttribute; import org.apache.nifi.annotation.behavior.ReadsAttributes; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.documentation.CapabilityDescription; import org.apache.nifi.annotation.documentation.SeeAlso; import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.AbstractProcessor; import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessSession; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processor.Relationship; import org.apache.nifi.processor.util.StandardValidators; import java.util.ArrayList; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; @Tags({"example"}) @CapabilityDescription("Provide a description") @SeeAlso({}) @ReadsAttributes({@ReadsAttribute(attribute="", description="")}) @WritesAttributes({@WritesAttribute(attribute="", description="")}) public class MyProcessor extends AbstractProcessor { public static final PropertyDescriptor MY_PROPERTY = new PropertyDescriptor .Builder().name("MY_PROPERTY") .displayName("My property") .description("Example Property") .required(true) .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final Relationship MY_RELATIONSHIP = new Relationship.Builder() .name("MY_RELATIONSHIP") .description("Example relationship") .build(); private List<PropertyDescriptor> descriptors; private Set<Relationship> relationships; @Override protected void init(final ProcessorInitializationContext context) { final List<PropertyDescriptor> descriptors = new ArrayList<PropertyDescriptor>(); descriptors.add(MY_PROPERTY); this.descriptors = Collections.unmodifiableList(descriptors); final Set<Relationship> relationships = new HashSet<Relationship>(); relationships.add(MY_RELATIONSHIP); this.relationships = Collections.unmodifiableSet(relationships); } @Override public Set<Relationship> getRelationships() { return this.relationships; } @Override public final List<PropertyDescriptor> getSupportedPropertyDescriptors() { return descriptors; } @OnScheduled public void onScheduled(final ProcessContext context) { } @Override public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { FlowFile flowFile = session.get(); if ( flowFile == null ) { return; } ////// Code here ///////////////// session.transfer(flowFile, MY_RELATIONSHIP); } } Thanks a lot ... View more

Dears I managed to create simple InvokeScriptedProcessor.. Code is working fine. However, if I made code error intentionally I get the below error, UndeclaredThrowableException. 2018-12-11 12:30:59,400 WARN [Timer-Driven Process Thread-7] o.a.n.c.t.ContinuallyRunProcessorTask Administratively Yielding InvokeScriptedProcessor[id=115d1249-1fba-1c84-7af8-8918fa3e1ecd] due to uncaught Exception: java.lang.reflect.UndeclaredThrowableException 2018-12-11 12:30:59,400 WARN [Timer-Driven Process Thread-7] o.a.n.c.t.ContinuallyRunProcessorTask java.lang.reflect.UndeclaredThrowableException: null Code: import java.nio.charset.StandardCharsets import java.io.IOException class TESTSCRIPT implements Processor { def REL_SUCCESS = new Relationship.Builder() .name("success") .description("The flowfile with the specified query results was successfully transferred.") .build(); def REL_FAILURE = new Relationship.Builder() .name("failure") .description("An error occured while running the specified query.") .build(); def REL_BACK = new Relationship.Builder() .name("backup") .description("Backup files.") .build(); def PORT_NUMBER = new PropertyDescriptor.Builder() .name('Port number') .description('Port number') .required(true) .expressionLanguageSupported(true) .addValidator(StandardValidators.PORT_VALIDATOR) .build() def FILENAME = new PropertyDescriptor.Builder() .name('File Name') .description('Sets the filename attribute of the flowfile (do not include the extension).') .required(true) .expressionLanguageSupported(true) .addValidator(Validator.VALID) .build() def ComponentLog log @Override void initialize(ProcessorInitializationContext context) { log = context.getLogger() } @Override Set<Relationship> getRelationships() { return [REL_SUCCESS, REL_FAILURE, REL_BACK] as Set } @Override void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException { ///// Code def session = sessionFactory.createSession() def flowFile = session.get() if(!flowFile) return def FILENAME = context.getProperty(FILENAME).value def PORT_NUMBER = context.getProperty(PORT_NUMBER).value flowFile = session.write(flowFile, {inputStream, outputStream -> inputStream.eachLine { line -> def a = line.split("\\|", -1) outputStream.write("${PORT_NUMBER}: Test\n".toString().getBytes(StandardCharsets.UTF_8)) } } as StreamCallback) flowFile = session.putAttribute(flowFile, "filename", FILENAME) try { FlowFile flowFilec = session.clone(flowFile); //log.error("ExecuteScript: transfer file") session.transfer(flowFile, REL_SUCCESS) session.transfer(flowFilec, REL_BACK) session.commit() } catch (e) { log.error('Scripting error: ', e) session.transfer(flowFile, REL_FAILURE) //session.rollback(true) session.commit() } } //////////// @Override Collection<ValidationResult> validate(ValidationContext context) { return null } @Override PropertyDescriptor getPropertyDescriptor(String name) { switch(name) { case 'File Name': return FILENAME case 'SMPP Port number': return PORT_NUMBER default: return null } } @Override void onPropertyModified(PropertyDescriptor descriptor, String oldValue, String newValue) { } @Override List<PropertyDescriptor> getPropertyDescriptors() { return [FILENAME, PORT_NUMBER] as List } @Override String getIdentifier() { return 'TESTSCRIPT-InvokeScriptedProcessor' } } processor = new TESTSCRIPT() Not sure why this Exception is generated, how can I handle it? so I get only the errors that are related to the code problem ... View more

Hello forum, I have the below sample record which should be inserted into mongoDB, Fields in bold should be recognized as datetime in mongo DB, I tried to change the schema but with no luck, getting int64 and string for both bold fields 10|AASDP08A|2191043285578215688|790000000||20180422000145|1343|0||SDP|AASDP08A|81167l|20180422000145+0300 Schema {"name": "CDR_TYPE", "type": ["null", "string"]}, {"name": "SDP_ID", "type": ["null", "string"]}, {"name": "CDR_ID", "type": ["null", "string"]}, {"name": "ACCOUNT_NUMBER", "type": ["null", "long"]}, {"name": "SUBSCRIBER_NUMBER", "type": ["null", "long"]}, {"name": "TIMES_TAMP", "type":{"type":"long","logicalType":"timestamp"} }, {"name": "SERVICE_CLASS_ID", "type": ["null", "string"]}, {"name": "CURRENCY_TYPE", "type": ["null", "string"]}, {"name": "ORIGIN_OPERATOR_ID", "type": ["null", "string"]}, {"name": "ORIGIN_NODE_TYPE", "type": ["null", "string"]}, {"name": "ORIGIN_NODE_ID", "type": ["null", "string"]}, {"name": "ORIG_TRANSACTION_ID", "type": ["null", "string"]}, {"name": "ORIG_TRANSACTION_TIME_STAMP", "type":{"type":"string","logicalType":"timestamp"} }, if you can advise please what should I change, ... View more

Hello forum, I have the below Groovy script which fetch the content of flowfile and send HTTPPost request per line, code is working fine However, Im not able to put this statement "con = (HttpURLConnection) obj.openConnection()" outside for eachLine loop ? I don't want to create object for everyline, I want to create the con object once at the begining of handling the flowfile then use it for everyline.. is this possible ? is it possible to put the code between the //////////// in one method and call it from the eachLine ? import java.nio.charset.StandardCharsets import java.text.DateFormat import java.text.ParseException import java.text.SimpleDateFormat import java.net.HttpURLConnection import java.net.URL import java.io.BufferedReader import java.io.DataOutputStream import java.io.InputStreamReader def rechargeLocation="" def url = "http://172.16.24.15:10000" def flowFile = session.get() if(!flowFile) return try { URL obj = new URL(url) HttpURLConnection con BufferedReader br DataOutputStream wr flowFile = session.write(flowFile, {inputStream, outputStream -> inputStream.eachLine { line -> def a = line.split("\\|", -1) if (a[20]!="N/A"){ rechargeNumber = a[23] rechargeLocation = a[116] ////////////////// con = (HttpURLConnection) obj.openConnection() con.setRequestMethod("POST") con.setRequestProperty("User-Agent", "Mozilla/5.0") con.setRequestProperty("Accept-Language", "en-US,en;q=0.5") con.setDoOutput(true) String urlParameters = "rechargeNumber=" + rechargeNumber + "&rechargeLocation=" + rechargeLocation // Send post request wr = new DataOutputStream(con.getOutputStream()) wr.writeBytes(urlParameters) wr.flush() wr.close() int responseCode = con.getResponseCode() br = new BufferedReader(new InputStreamReader(con.getInputStream())) String inputLine StringBuilder response = new StringBuilder() while ((inputLine = br.readLine()) != null) { response.append(inputLine) } br.close() log.warn("Sending " + con.getRequestMethod() + " request to URL: " + url + ": Response Code: " + responseCode + " :Response: " + response.toString) con.disconnect() //Response = response.toString /////////////////////////////////////// outputStream.write("${rechargeNumber},${rechargeLocation}\n".toString().getBytes(StandardCharsets.UTF_8)) } } } as StreamCallback) session.transfer(flowFile, REL_SUCCESS) } catch (IllegalArgumentException | Exception ex) { log.error("ExecuteScript: General Exception. " + ex) session.transfer(flowFile, REL_FAILURE)} ... View more