2020-01-15 14:43:21 -05:00
..
2019-11-04 13:31:39 -05:00
2019-11-25 13:35:21 -05:00
2019-12-18 16:37:47 -05:00
2019-11-04 13:31:39 -05:00
2019-11-04 13:31:39 -05:00
2020-01-10 10:44:59 -08:00
2019-11-04 13:31:39 -05:00
2019-11-25 10:58:22 -05:00
2019-11-04 13:31:39 -05:00
NIFI-7011: This closes #3983. SwappablePriorityQueue contains two internal data structures: activeQueue, swapQueue. activeQueue is intended to be pulled from for processing. swapQueue is intended to hold FlowFiles that are waiting to be swapped out. SinWe want to ensure that we first swap in any data that has already been swapped out before processing the swap queue, in order to ensure that we process the data in the correct order. This fix ddresses an issue where data was being swapped out by writing the lowest priority data to a swap file, then adding the highest priority data to activeQueue and the 'middle' priority data back to swapQueue. As a result, when polling from the queue we got highest priority data, followed by lowest priority data, followed by middle priority data. This is addressed by avoiding putting anything back on swapQueue when we swap out. Instead, write data to the swap file, then push everything else to activeQueue. This way, any new data that comes in will still go to the swapQueue, as it should, but all data that didn't get written to the Swap file will be processed before the low priority data in the swap file.
2020-01-13 22:02:05 -05:00
2020-01-13 13:59:11 -05:00
2020-01-13 13:59:11 -05:00
2020-01-13 13:59:11 -05:00
2019-11-04 13:31:39 -05:00
2020-01-13 13:59:11 -05:00
2020-01-10 10:44:59 -08:00
2019-11-04 13:31:39 -05:00
2020-01-15 14:43:21 -05:00
2019-11-08 12:33:16 -05:00
2019-11-04 13:31:39 -05:00
2019-11-04 13:31:39 -05:00
2019-11-08 12:33:16 -05:00
2019-11-04 13:31:39 -05:00
2019-11-25 10:58:22 -05:00
2019-11-04 13:31:39 -05:00
2020-01-13 12:12:34 -08:00
2019-11-04 13:31:39 -05:00
