传统的关系模型和 SQL 最开始都是为了批式处理而设计的，当把一个关系型查询应用到流式处理上时，在实现和转换的过程中，会有很多和批处理场景非常不同的地方，典型的例子就是：为了实现 SQL 的某些语义，Flink 必须在流上维持状态，典型的代表就是：连接、聚合 、去重 这些操作，它们都是“状态算子”，本质原因还是因为：流处理的表是无界的，流式查询是持续不停的，所以在流上维持状态是必须的。