Flink: состояние доступа через поток?

Question

У меня один поток собирается сохранить состояние, и я надеюсь, что другой поток может получить состояние.Возможно ли это?

Я пытался в своем модульном тесте, похоже, не работает.

Answer 1

В зависимости от того, как вам нужно использовать состояние, можно использовать запрашиваемое состояние , чтобы поделиться им с другим потоком.

Answer 2

В настоящее время невозможно, чтобы разные потоки совместно использовали состояние.Даже разные операторы, принадлежащие одному и тому же потоку, не могут совместно использовать состояние.

Единственное, с чем вы можете поиграть, это использовать статические поля для совместного использования состояния между различными потоками и, следовательно, также потоками.Но это работает, только если разные задачи выполняются одним и тем же TaskManager и, таким образом, выполняются в одной и той же JVM.