xishuaidelin commented on code in PR #24240: URL: https://github.com/apache/flink/pull/24240#discussion_r1477642832
########## docs/content.zh/docs/dev/table/tuning.md: ########## @@ -259,5 +259,23 @@ GROUP BY day Flink SQL 优化器可以识别相同的 distinct key 上的不同过滤器参数。例如，在上面的示例中，三个 COUNT DISTINCT 都在 `user_id` 一列上。Flink 可以只使用一个共享状态实例，而不是三个状态实例，以减少状态访问和状态大小。在某些工作负载下，可以获得显著的性能提升。 +## MiniBatch Join +默认情况下，普通join算子是逐条处理输入的记录，即：（1）从状态中根据joinKey查询记录，（2）将当前记录写到对应状态，（3）处理输入和从状态中查找出的记录。这种处理模式可能会增加 StateBackend 开销（尤其是对于 RocksDB StateBackend ）。 Review Comment: done -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
