状态 概述 在流处理任务中，数据会以连续的流的形式输入到Flink中，而状态计算允许我们跟踪和处理这些输入数据的状态信息。状态可以是任何需要记录和使用的数据，例如聚合计数、累积结果、窗口中的中间状态等。 Flink中的状态管理是指在流处理任务中对数据的状态进行有效管理和维护的过程。状态管理是非常重要的，因为它允许我们在流式处理中维护和操作数据的状态信息，以实现复杂的计算逻辑和应用需求。 状态分类 在Flink中，Flink状态有两种：系统状态ManagedState和原始状态RawState。通常使用系统状态，而原始状态则需要自定义实现。 系统状态根据数据集是否按照某一个Key...