Блог

У меня есть поток данных в Flink следующим образом:

Источник -gt; Оператор -gt;gt; Ссылка на удаление

Есть ли какая-то разница между этим и тем, у которого нет раковины?

Источник -gt; Оператор -gt;gt;

Из моих тестов кажется, что он работает так же, хотя в первом случае я вижу, что оператор и приемник связаны и из приемника не отправляются записи. Во втором случае я вижу, что записи пересылаются, но им некуда идти.

Насколько я понимаю, Оператор будет заполнять свои исходящие сетевые буферы записями, и я ожидал бы в какой-то момент увидеть обратное давление, но этого не происходит, так какова семантика, которую я должен ожидать здесь?