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/16 07:45:32 UTC

[flink] branch release-1.10 updated (2bf5ea2 -> 5c0f827)

This is an automated email from the ASF dual-hosted git repository.

zhijiang pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 2bf5ea2  [FLINK-17891][yarn] Set execution.target=yarn-session in FlinkYarnSessionCli.run()
     add 5fc4d1b  [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.
     add 5c0f827  [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   |  8 ++
 .../runtime/io/network/buffer/BufferConsumer.java  | 14 ++++
 .../api/writer/BroadcastRecordWriterTest.java      | 54 +++++++++++++
 .../api/writer/RecordWriterDelegateTest.java       | 12 ++-
 .../io/network/api/writer/RecordWriterTest.java    | 73 ++++++++++++++++-
 .../buffer/BufferBuilderAndConsumerTest.java       | 16 +---
 .../partition/NoOpBufferAvailablityListener.java   |  2 +-
 .../streaming/runtime/LatencyMarkerITCase.java     | 93 ++++++++++++++++++++++
 10 files changed, 264 insertions(+), 19 deletions(-)
 create mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/LatencyMarkerITCase.java