Realized during testing that as a result of creating a new FlowFile from the incoming FlowFile, we can't call commitAsync in the middle of onTrigger as that prevents more FlowFiles from being created from the incoming one.
As a result, reworked several processors so that they only call commitAsync() once - at the end of onTrigger, regardless of whether an error occurs or not.
Also added a missing test scenario for DeleteMarkLogic where the user is able to read URIs but not delete them. This tests the "on batch failure" listener in DeleteMarkLogic.
Realized during testing that as a result of creating a new FlowFile from the incoming FlowFile, we can't call commitAsync in the middle of
onTriggeras that prevents more FlowFiles from being created from the incoming one.As a result, reworked several processors so that they only call
commitAsync()once - at the end ofonTrigger, regardless of whether an error occurs or not.Also added a missing test scenario for
DeleteMarkLogicwhere the user is able to read URIs but not delete them. This tests the "on batch failure" listener inDeleteMarkLogic.