I want to remove session in case i get certain data from file i have code like this,but i got errors "flowfile has already marked for removal", what should i change to get rid of extra errors? In case of session rollback flowfile will dissapear in queues also? 2.should i use rollback instead of remove()? NodeList childNodes = nodeGettingChanged.getChildNodes();for(int i =0; i != childNodes.getLength();++i){Node child = childNodes.item(i);if(!(child instanceofElement))continue;if(child.getNodeName().equals("runAs")){if(child.getFirstChild().getTextContent()=="false"){
session.remove(flowFile1);File deleteExtraFile =newFile("C://Users//s.tkhilaishvili//Desktop//try2//nifi-1.3.0//1//conf.xml");booleandelete=deleteExtraFile.delete();}else{
child.getFirstChild().setNodeValue("false");}}} Document finalXmlDocument = xmlDocument; session.write(flowFile1, new StreamCallback() { publicvoid process(InputStream inputStream,OutputStream outputStream)throwsIOException{TransformerFactory transformerFactory =TransformerFactory.newInstance();Transformer transformer =null;try{
transformer = transformerFactory.newTransformer();}catch(TransformerConfigurationException e){
e.printStackTrace();}DOMSource source =newDOMSource(finalXmlDocument);
ffStream.close();ByteArrayOutputStream bos =newByteArrayOutputStream();StreamResult result =newStreamResult(bos);try{
transformer.transform(source, result);}catch(TransformerException e){
e.printStackTrace();}byte[] array = bos.toByteArray();
outputStream.write(array);}});
session.remove(flowFile);
session.transfer(flowFile1, REL_SUCCESS);}
... View more
