You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by zh...@apache.org on 2020/06/12 15:00:59 UTC

[flink] branch master updated (4d8f55e -> 7e7b132)

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