退订

flink-spillable-statebackend????????????

?? flink-1.11??spillable-statebackendOOM //spillableStateBackend env.setStateBackend(new SpillableStateBackend(path)); -yD jobmanager.memory.process.size=4096m \ -yD

????intervaljoin????????????????jobmanager.execution.failover-strategy??region????????????????task cancel

??flink??1.8.1??jobmanager.execution.failover-strategy??region kill??taskmanagershuffleregion??source??cancelDEPLOYcancel?? ??1300

??????RocksDBKeyedStateBackend??????????

writerbuffer??flushcheckpoint??snapshot??rocksdb??checkpointsst?? ---- ??:

????????????flink????????????????

flinkflink-1.8.1 org.apache.flink.runtime.executiongraph.ExecutionGraphException: Trying to eagerly schedule a task whose inputs are not ready (result type: PIPELINED_BOUNDED, partition consumable: false, producer state: SCHEDULED, producer slot: null).at

Trying to eagerly schedule a task whose inputs are not ready

flink org.apache.flink.runtime.executiongraph.ExecutionGraphException: Trying to eagerly schedule a task whose inputs are not ready (result type: PIPELINED_BOUNDED, partition consumable: false, producer state: SCHEDULED, producer slot: null).at