Apache Flink：如何更改缓冲区超时参数？

Question

Apache Flink缓冲任务的传出，然后将其发送到下一个任务进行处理。缓冲会影响延迟，而且正如我所知，即使缓冲区没有填满，也会有一个缓冲超时，以便将数据发送到下一个任务。

• 如何更改缓冲超时？我在留档中找不到任何东西。
• 配置是每个Flink集群还是每个TaskManager？它可以按任务/运算符配置吗？
• 据我所知，即使任务在同一个TaskManager上，Flink缓冲区也是如此。在这种情况下，它会影响位于同一个TaskManager中的任务/运算符。我说得对吗？

注意：我对这些数据/信息/问题的参考是O'Reilly的“使用Apache Flink进行流处理”和官方留档。

Answer 1

缓冲区超时是一个作业级参数，通过StreamExecutionEnvironment配置。

val env: StreamExecutionEnvironment = ???
env.setBufferTimeout(50L) // configure 50 ms buffer timeout

不能按操作员配置。此外，每个TaskManager的发送方-接收方对，所有操作员的传出通道都被多路复用到单个物理连接中。因此，所有操作员都将其输出写入同一个缓冲区，需要将其发送到同一个TaskManager。

该参数在留档中有更详细的描述。