Extract those initialisations to setup/teardown/`@Rule`. This code block is
duplicated couple of times:
```
final ResultSubpartition subpartition = createSubpartition();
AwaitableBufferAvailablityListener availablityListener = new
AwaitableBufferAvailablityListener();
ResultSubpartitionView readView =
subpartition.createReadView(availablityListener);
availablityListener.resetNotificationCounters();
(...)
} finally {
subpartition.release();
}
```
[ Full content available at: https://github.com/apache/flink/pull/6692 ]
This message was relayed via gitbox.apache.org for [email protected]
