As said in apache page, Flink's streaming runtime has natural flow control: Slow downstream operators backpressure faster upstream operators.How to understand the flink natural flow control? As i know, heron has the backpressure mechanism, if some tasks process slowly, it will stop reading from source and notify other tasks to stop reading from source.In flink, if the producer task process quickly, it will emit the results to consumer. So the buffer in InputChannel of consumer wil be filled up, if the consumer process slowly, how to control the upstream flow? Thank you for any suggestions in advance!
Best wishes, Zhijiang Wang
