Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
1.12.1
-
None
-
None
Description
Try to execute below groovy script
FlowFile ff = session.get() OutputStream os = session.write(ff) os.write("1".getBytes("UTF-8")) os.flush() os.close() session.transfer(ff, REL_SUCCESS) os.write("2".getBytes("UTF-8")) os.flush() os.close()
in success queue you find 1 flowfile with 1 byte size but in content repository you can find
file with content "12"
In this way NiFi write all content after stream was closed but not claim it.
write(ff) in MockProcessSession has the same problem.