Github user majakabiljo commented on a diff in the pull request:
https://github.com/apache/giraph/pull/96#discussion_r240745235
--- Diff:
giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyClient.java ---
@@ -1147,8 +1158,11 @@ private void checkRequestsAfterChannelFailure(final
Channel channel) {
resendRequestsWhenNeeded(new Predicate<RequestInfo>() {
@Override
public boolean apply(RequestInfo requestInfo) {
- return requestInfo.getDestinationAddress().equals(
- channel.remoteAddress());
+ if (requestInfo.getWriteFuture() == null ||
--- End diff --
It can happen if the request wasn't sent out yet, not sure if there is some
other scenario.
---
