This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4d8f55e [FLINK-18259][tests] Increase heartbeat timeouts for
HeartbeatManagerTest
add ca9dc71 [FLINK-17322][network] Fixes BroadcastRecordWriter
overwriting memory segments on first finished BufferConsumer.
add 7e7b132 [FLINK-17322][network] Disallowing repeated consumer creation
for BufferBuilder.
No new revisions were added by this update.
Summary of changes:
.../network/api/writer/BroadcastRecordWriter.java | 6 +-
.../io/network/api/writer/RecordWriter.java | 5 ++
.../runtime/io/network/buffer/BufferBuilder.java | 10 ++-
.../runtime/io/network/buffer/BufferConsumer.java | 14 ++++
.../api/writer/BroadcastRecordWriterTest.java | 54 +++++++++++++
.../api/writer/RecordWriterDelegateTest.java | 10 ++-
.../io/network/api/writer/RecordWriterTest.java | 13 ++-
.../buffer/BufferBuilderAndConsumerTest.java | 16 +---
.../streaming/runtime/LatencyMarkerITCase.java | 93 ++++++++++++++++++++++
9 files changed, 199 insertions(+), 22 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/LatencyMarkerITCase.java
