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