0
Для оператора входной поток быстрее, чем его выходной поток, поэтому его входной буфер блокирует выходной поток предыдущего оператора, который передает данные этому оператору. Правильно?Apache Flink: Как он обрабатывает противодавление?
Нужно ли Flink и Spark обрабатывать противодавление, блокируя резьбу? Так в чем разница между ними?
Для источника данных он непрерывно производит данные, что, если его выходной поток заблокирован? Будет ли переполнение буфера?