[flink] 15/16: [hotfix][network] Minor code simplification in CachedBufferStorage

[pnowojski]

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

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 777aefb84574a039f4030116519cda2347d9b679
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Wed Jun 26 16:51:07 2019 +0200

    [hotfix][network] Minor code simplification in CachedBufferStorage
---
 .../java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java
index 318497d..033ff15 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CachedBufferStorage.java
@@ -88,7 +88,7 @@ public class CachedBufferStorage extends 
AbstractBufferStorage {
                }
 
                CachedBufferOrEventSequence currentSequence = new 
CachedBufferOrEventSequence(currentBuffers, bytesBlocked);
-               currentBuffers = new ArrayDeque<BufferOrEvent>();
+               currentBuffers = new ArrayDeque<>();
                bytesBlocked = 0L;
 
                return currentSequence;