????Flink??????????????????
??????????????????????StateBackend??????????????????env.setStateBackend(new
RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true))????????????????????SQLwindow????????checkpoint??????????????????n/a??
????????????????????????????????????flink-conf.xml??????????
state.checkpoints.dir:
hdfs://host51:9000/flink/flink-checkpoints??????????????????
????SQLwindow??RocksDBStateBackend????????????????????????????????
