Не волнуйтесь, широковещательное состояние (как и все состояния оператора) включено в контрольные точки Флинка. Но его рабочее состояние находится в памяти (в куче JVM) независимо от выбора внутреннего состояния. Только состояние ключа может храниться в RocksDB.
RocksDB - это локальное встроенное хранилище ключей / значений, которое сохраняет свое рабочее состояние на локальном диске с кэшем вне кучи. Если вы используете RocksDB в качестве бэкэнда состояния, то при возникновении контрольных точек состояние оператора в куче и состояние ключа из RocksDB будут скопированы в контрольную точку. Контрольные точки не хранятся в RockDB, а вместо этого записываются в распределенную файловую систему вне узла для обеспечения долговечности.
Просто путь, не используйте createNativeQuery, просто используйте createQuery.. или сделайте переходный процесс с методом get convat
Действительно, похоже, это проблема, о которой сообщалось в HHH-2225 (который HHH-2536 дублирует). К сожалению, проблема не исправлена, и я боюсь, что вам придется либо использовать HQL, либо отправить патч (вы можете начать с голосования по этому вопросу, но я бы не ожидал быстрого решения, учитывая, что этому вопросу почти четыре года).