Apache Flink: How to change the buffer timeout parameter?

Viewed 1423

Apache Flink buffers the outgoing of a task and then send it next task for processing. The buffering affects latency and as I know there is a timeout for buffering to send data to next task even if buffer isn't filled.

  • How I can change the buffering timeout? I couldn't find anything in documentation.
  • Is the configuration per Flink cluster or per TaskManager? Can it be configured per task/operator?
  • As I know Flink buffers even if tasks are on the same TaskManager. In this condition it will affect the tasks/operators that are in the same TaskManager. Am I right?

Note: My reference for this data/information/questions is O'Reilly's "Streaming Processing with Apache Flink" and official documentation.

1 Answers
Related