В этот раз у меня вопрос: работая с MapState, можно безопасно использовать mapstate.put(key, value) для изменения текущего значения ключа в mapState, или мне нужно сделать mapState.remove(key), а после этого снова сделать mapstate.put(key, value) или есть ли возможность обновить это значение?
Начиная с абстракций состояния Flink, они не предназначены для одновременного доступа и не должны совместно использоваться несколькими потоками. Итак, переформулируя мой вопрос: могу ли я обновить значение в соответствии с ключом в mapState, не удаляя ключ, а затем снова вставив ключ? и как я могу избежать исключения ConcurrentModificationException с использованием mapState, не устанавливая параллелизм для этого оператора? С уважением.