一、FlinkState概念 State用于记录Flink应用在运行过程中，算子的中间计算结果或者元数据信息。运行中的Flink应用如果需要上次计算结果进行处理的，则需要使用状态存储中间计算结果。如Join、窗口聚合场景。 Flink应用运行中会保存状态信息到State对象实例中，State对象实例通过StateBackend实现将相关数据存储到FS文件系统或者RocksDB数据库中。在Flink应用运行过程中，通过checkpoint快照定期地保存状态数据。并在Flink应用重启时加载checkpoint/savepoint来实现状态的恢复，从而让Flink应用继续完成之前的数据计算，实现数...