Я использую шаблон состояния широковещания, где правила передаются всем операторам.
В административных целях я хотел бы получить доступ к содержимому состояния широковещания вне приложения flink. В целях отладки я хотел бы посмотреть, какие все правила хранятся в состоянии широковещания в моем кластере flink.
Документация о состоянии Queryable указывает на то, что это только для состояния управляемого ключа:
https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html
Когда я попытался установить имя запроса в дескриптор состояния широковещания, я получил следующее исключение:
java.lang.IllegalStateException: Queryable state name already set
at org.apache.flink.api.common.state.StateDescriptor.setQueryable(StateDescriptor.java:218)
- Может ли широковещательное состояние запрашиваться извне кластера Flink?
- Если нет, какие еще есть варианты?