Hi,
flink 1.11 on k8sjoin??sql??rocksdbbackend??flink
managedflink??state.backend.rocksdb.memory.managed=truek8s??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='6 ms';
taskmanager.memory.flink.size =55 gb
taskmanager.memory.managed.fraction=0.85
??
1. checkpoint??size??200G??state
2. k8s
podpodpod??pod
3. promethus??metrics,
rocksdb_block_cache_usagerocksdb_block_cache_capacityrocksdb_block_cache_usageflink
managed
flink??rocksdb??rocksdb_block_cache_usage
