Hi,
Is a flowfile's lastQueueDate updated if a processor just passes the flowfile
through without doing anything?
I’m running NiFi 0.5.1 on Mac with a customized processor. The incoming and
outgoing connections of this processor uses FirstInFirstOutPrioritizer because
the order of flowfiles is critical for me. The processor would perform
different operations based on the flowfiles’ attributes. In some cases the
processor would just transfer the flowfiles without doing anything. What I’ve
observed is that these pass-through flowfiles’ lastQueueDate field is not
updated. As a result FirstInFirstOutPrioritizer always puts them at the
beginning of the connection queue, despite that some other flowfiles arrive
before them. Is this an expected behavior?
The flow of the processor is something like:
FlowFile flowFile = session.get();
if (flowFile.getAttribute(myAttr) == NOOP) {
session.transfer(flowFile, REL_SUCCESS);
session.commit();
return;
}
…
Thanks,
Ben
________________________________
The information contained in this transmission may contain privileged and
confidential information. It is intended only for the use of the person(s)
named above. If you are not the intended recipient, you are hereby notified
that any review, dissemination, distribution or duplication of this
communication is strictly prohibited. If you are not the intended recipient,
please contact the sender by reply email and destroy all copies of the original
message.
________________________________
