| commit | 8c6c58799a7e24f9e3c3472b2ce89dde4ae43d2c | [log] [tgz] |
|---|---|---|
| author | Dionysios Logothetis <dlogothetis@gmail.com> | Mon Nov 18 21:58:44 2019 -0800 |
| committer | Dionysios Logothetis <dionysios@fb.com> | Mon Nov 18 21:58:44 2019 -0800 |
| tree | 45414a4350ebb313999280015024b3e32a04b876 | |
| parent | acc1f71af03dec6f1a1c83fb0fcce08451e140ea [diff] |
closes #116
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyClient.java b/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyClient.java index 3c0363c..c8ccea2 100644 --- a/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyClient.java +++ b/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyClient.java
@@ -340,7 +340,6 @@ /*if_not[HADOOP_NON_SECURE]*/ if (conf.authenticate()) { LOG.info("Using Netty with authentication."); - PipelineUtils.addLastWithExecutorCheck("flushConsolidation", new FlushConsolidationHandler(FlushConsolidationHandler .DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES, true),