Hi,
????flink 1.11 on k8s????????????????join??sql??????rocksdb????backend??flink managed????????????flink??????state.backend.rocksdb.memory.managed=true????????????k8s??pod???????????????????????????????????? flink sql: insert into console_sink select t1.*, t2.* from t1 left join t2 on t1.unique_id = t2.unique_id and t1.event_time BETWEEN t2.event_time - INTERVAL '1' HOUR AND t2.event_time + INTERVAL '1' HOUR ?????????? state.backend=rocksdb; state.backend.incremental=false; state.backend.rocksdb.memory.managed=true state.idle.retention.mintime='10 min'; state.idle.retention.maxtime='20 min'; checkpoint.time.interval='15 min'; source.idle-timeout='60000 ms'; taskmanager.memory.flink.size =55 gb taskmanager.memory.managed.fraction=0.85 ?????????? 1. checkpoint??size??????200G??????????state???????????????? 2. k8s pod????????????????????????????????????????????????pod????????????????pod??????????????pod???????? 3. ????????promethus??metrics, ????rocksdb_block_cache_usage????????????????????????rocksdb_block_cache_capacity????????????rocksdb_block_cache_usage????????????????flink managed???????????????? ????????????????flink??????rocksdb??????????????????????rocksdb_block_cache_usage????????????????????????????
