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 2019/10/21 02:04:41 UTC

[flink] branch master updated (2e9f16e -> 47e9a82)

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 2e9f16e  [hotfix][doc] fix typo in RuntimeContext
     add ccfb82e  [hotfix][task] Fix the code formatting in StreamTask
     add 09c2c98  [hotfix][runtime] Remove legacy NullableAsyncDataInput class
     add 34e53d1  [hotfix][network] Remove optional class field from LocalBufferPool
     add 47e9a82  [FLINK-14394][network] Remove unnecessary interface method BufferProvider#requestBufferBlocking

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/io/NullableAsyncDataInput.java   | 39 ----------------------
 .../io/network/buffer/BufferPoolFactory.java       |  9 +++--
 .../runtime/io/network/buffer/BufferProvider.java  |  8 -----
 .../runtime/io/network/buffer/LocalBufferPool.java | 33 ++++++++----------
 .../io/network/buffer/NetworkBufferPool.java       | 15 ++++++---
 .../network/partition/ResultPartitionFactory.java  |  5 ++-
 .../network/buffer/LocalBufferPoolDestroyTest.java |  2 +-
 .../io/network/buffer/LocalBufferPoolTest.java     |  8 +++--
 .../io/network/buffer/NetworkBufferPoolTest.java   |  9 +++--
 .../runtime/io/network/buffer/NoOpBufferPool.java  |  5 ---
 .../network/netty/CancelPartitionRequestTest.java  | 12 ++++---
 .../partition/consumer/RemoteInputChannelTest.java |  6 ++--
 .../io/network/util/TestPooledBufferProvider.java  |  3 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |  2 +-
 14 files changed, 55 insertions(+), 101 deletions(-)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/NullableAsyncDataInput.java