pvillard31 commented on code in PR #11815:
URL: https://github.com/apache/nifi/pull/11815#discussion_r4341089360
##########
nifi-framework-api/src/main/java/org/apache/nifi/controller/queue/FlowFileQueue.java:
##########
@@ -161,6 +161,16 @@ public interface FlowFileQueue {
*/
void put(FlowFileRecord file);
+ /**
+ * Places the given FlowFile onto the active portion of the queue, never
onto the swap queue, even if the queue is
+ * currently swapping FlowFiles out. This is intended for FlowFiles that
were previously polled from this queue and are
+ * being returned to it, such as on session rollback. Because such a
FlowFile was polled from the active queue, it was
+ * ahead of any FlowFiles that are swapped out, and placing it back onto
the active queue preserves that ordering.
+ *
+ * @param file the FlowFile to place onto the active queue
+ */
Review Comment:
I meant that the source queue for the Stateless PG comes from
`port.getIncomingConnections()` in the parent PG, not from the stateless
engine. Can that queue swap meaning that lines 397 and 404 have the same
reordering issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
