我尝试使用apache flink有状态函数来实现消息传递场景。
通过设计，我需要从传入的消息中计算一些统计信息，并将它们存储在状态中。之后，场景函数将访问这些状态和消息，并对它们运行业务规则。但是每个消息可能有几十个场景，每个场景应该只运行一次。
代码大致如下

@Override
    public void configure(MatchBinder binder) {
        binder
            .predicate(Transaction.class,this::updateTransactionStatAndSendToScenatioManager)
}

    private void updateTransactionStatAndSendToScenatioManager(Context context, Transaction transaction){
        // state update
        context.send(FnScenarioManager.TYPE,  String.valueOf(transaction.id()) , transaction);
    }

现场经理：

@Override
    public void configure(MatchBinder binder) {
    binder
        .predicate(Transaction.class,this::runTransactionScenarios);
}

private void runTransactionScenarios(Context context, Transaction transaction){
   context.send(Scenario1.TYPE,String.valueOf(transaction.id()),transaction);
   context.send(Scenario2.TYPE,String.valueOf(transaction.id()),transaction);
   context.send(Scenario3.TYPE,String.valueOf(transaction.id()),transaction);
   ...
   context.send(ScenarioN.TYPE,String.valueOf(transaction.id()),transaction);
}

我的问题是，如果集群在runtransactionscenarios中崩溃，会发生什么？
每个场景是否只运行一次？如果不是，我怎么能保证？