состояние трансляции flink не сохраняется в rocksdb, когда произошла контрольная точка?
Идентификаторы всегда должны быть уникальными.
Каждый имеет уникальный идентификационный номер (например, номер социального страхования), и в социальном классе
есть много людей]1 ответ
Не волнуйтесь, широковещательное состояние (как и все состояния оператора) включено в контрольные точки Флинка. Но его рабочее состояние находится в памяти (в куче JVM) независимо от выбора внутреннего состояния. Только состояние ключа может храниться в RocksDB.
RocksDB - это локальное встроенное хранилище ключей / значений, которое сохраняет свое рабочее состояние на локальном диске с кэшем вне кучи. Если вы используете RocksDB в качестве бэкэнда состояния, то при возникновении контрольных точек состояние оператора в куче и состояние ключа из RocksDB будут скопированы в контрольную точку. Контрольные точки не хранятся в RockDB, а вместо этого записываются в распределенную файловую систему вне узла для обеспечения долговечности.