Я должен объединить счет / сумму в потоке событий для различных объектов. Журналы событий (json str) принимаются от kafka и заполняют имя сущности карты как ключ, а значением является счетчик выборочных атрибутов как json str.
MapState sourceAggregationMap = getRuntimeContext (). GetMapState (sourceAggregationDesc);
для каждого потока событий, заполняющего значение.
Проблема в том, что когда диспетчер задач останавливается или выходит из строя, и когда диспетчер задач перезапускается, состояние карты не переинициализируется / восстанавливается. снова отсчет начинается с 0.
с использованием Apache flink 1.6.0 state.backend: rocksdb