This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6343e37 [FLINK-24469][runtime] Allow to have zero number of buffers
in use for channels
add da9e183 [FLINK-24465] Fix disabling buffer timeout for pipelined
exchanges
No new revisions were added by this update.
Summary of changes:
.../flink/configuration/ExecutionOptions.java | 11 ++-
.../io/network/api/writer/RecordWriter.java | 8 +-
.../environment/StreamExecutionEnvironment.java | 5 +-
.../streaming/api/graph/StreamGraphGenerator.java | 2 +-
.../api/graph/StreamingJobGraphGenerator.java | 20 ++---
.../api/graph/StreamingJobGraphGeneratorTest.java | 22 +++++-
...hGeneratorWithGlobalStreamExchangeModeTest.java | 28 +++++--
.../flink/test/runtime/BlockingShuffleITCase.java | 1 +
.../streaming/runtime/BufferTimeoutITCase.java | 87 ++++++++++++++++++++++
9 files changed, 154 insertions(+), 30 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BufferTimeoutITCase.java
