This is an automated email from the ASF dual-hosted git repository.
abstractdog pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git
The following commit(s) were added to refs/heads/master by this push:
new 65f9ee32a TEZ-4455: Add LoggingHandler in ShuffleHandler pipeline for
better debuggability. (#249) (Dmitriy Fingerman reviewed by Laszlo Bodor)
65f9ee32a is described below
commit 65f9ee32a46518c89ad2347a8e39541d3e669e2d
Author: Dmitriy Fingerman <[email protected]>
AuthorDate: Wed Nov 23 14:25:58 2022 -0500
TEZ-4455: Add LoggingHandler in ShuffleHandler pipeline for better
debuggability. (#249) (Dmitriy Fingerman reviewed by Laszlo Bodor)
---
.../src/main/java/org/apache/tez/auxservices/ShuffleHandler.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
b/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
index 0fa1c03a9..3262c7c34 100644
---
a/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
+++
b/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
@@ -33,6 +33,8 @@ import static
io.netty.handler.codec.http.HttpResponseStatus.NOT_FOUND;
import static io.netty.handler.codec.http.HttpResponseStatus.OK;
import static io.netty.handler.codec.http.HttpResponseStatus.UNAUTHORIZED;
import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
import java.io.File;
import java.io.FileNotFoundException;
@@ -603,6 +605,9 @@ public class ShuffleHandler extends AuxiliaryService {
if (sslFactory != null) {
pipeline.addLast("ssl", new
SslHandler(sslFactory.createSSLEngine()));
}
+ if (LOG.isDebugEnabled()) {
+ pipeline.addLast("loggingHandler", new
LoggingHandler(LogLevel.DEBUG));
+ }
pipeline.addLast("decoder", new HttpRequestDecoder());
pipeline.addLast("aggregator", new HttpObjectAggregator(1 << 16));
pipeline.addLast("encoder", new HttpResponseEncoder());
