Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6355#discussion_r204325132
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyServer.java
---
@@ -61,6 +63,9 @@
private ChannelFuture bindFuture;
+ @Nullable
--- End diff --
Please deduplicate this code with `NettyClient`. Introduce `NettyBase`,
`NettyInitializer` or sth like that---
