Drools-фьюжн не evcting события из рабочей памяти, когда она должна

Question

у меня есть следующие 2 правила:

    rule "Backup Not Succeeded For At Least 3 Days" 
    @ruleId(1) 
    when 
     Node($id : id) 
     not (Backup(clientId == $id, $state: state == BackupStateEnum.FINISHED) over window:time(3d) from entry-point "Backup Stream") 
    then 
     //nothing for now 
    end 

    rule "Prune Previous Successful Backups" 
    @ruleId(2) 
    when 
     $prevBackup : Backup($id : clientId, state == BackupStateEnum.FINISHED) over window:time(3d) from entry-point "Backup Stream" 
     $newerBackup : Backup(clientId == $id, state == BackupStateEnum.FINISHED, this after $prevBackup) over window:time(3d) from entry-point "Backup Stream" 
    then 
     drools.retract($prevBackup); 
    end 

и «стресс-тест», который генерирует 10K таких резервных копий в день, и имитирующий 50 дней. учитывая, что все приведенные выше правила относятся к 3-дневному окну, и в системе нет других правил, должно быть не более 30K событий в памяти через 50 дней (меньше, так как успешные должны быть обрезаны). однако, когда я проверяю содержимое точки входа потока (WorkMemoryEntryPoint), у меня есть ~ 380K событий в памяти - это означает, что у меня есть некоторые очень старые события, которые не выселяются автоматически, как они должны.

КБ были сконфигурированы в режиме обработки потока, а событие определяются следующим образом:

declare Backup 
    @role(event) 
    @duration (duration) 
    @timestamp(finished) 
end 

поэтому нет явного управления жизненного цикла. что я делаю неправильно? Я знаю, что это имеет какое-то отношение к правилу № 2, потому что, если я его удалю, я получаю ровно 30 тыс. событий в памяти (10 тыс. в день * 3-дневное окно)

Answer 1

оказалась ошибка в Drools, так как фиксированный.

Answer 2

По вашему описанию, возможно, возникло нежелательное взаимодействие между оператор «после» и окно времени в вашем примере.

В своем втором правиле вы можете попробовать сбросить использование скользящих окон и параметризовать оператор «после», и он должен добиться эффекта, который вы ищете. Пример:

rule "Prune Previous Successful Backups" 
    @ruleId(2) 
    when 
     $prevBackup : Backup($id : clientId, state == BackupStateEnum.FINISHED) from entry-point "Backup Stream" 
     $newerBackup : Backup(clientId == $id, state == BackupStateEnum.FINISHED, this after[0,3d] $prevBackup) from entry-point "Backup Stream" 
    then 
     drools.retract($prevBackup); 
    end 

В любом случае, вы можете открыть JIRA для Drools команды, чтобы исследовать взаимодействие между скользящим окном и без параметров «после» оператора, как вы описали. Не забудьте указать версию Drools, которую вы используете.

Эдсон