[hive] branch master updated: HIVE-23754: LLAP, Add LoggingHandler in ShuffleHandler pipeline for better debuggability (#3669) (Dmitriy Fingerman reviewed by Laszlo Bodor)

[abstractdog]

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/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new cbaca7363c3 HIVE-23754: LLAP, Add LoggingHandler in ShuffleHandler 
pipeline for better debuggability (#3669) (Dmitriy Fingerman reviewed by Laszlo 
Bodor)
cbaca7363c3 is described below

commit cbaca7363c30b14929ac81d00e2c1f71c6eee8e6
Author: Dmitriy Fingerman <dmitriy.finger...@gmail.com>
AuthorDate: Tue Nov 22 08:32:56 2022 -0500

    HIVE-23754: LLAP, Add LoggingHandler in ShuffleHandler pipeline for better 
debuggability (#3669) (Dmitriy Fingerman reviewed by Laszlo Bodor)
---
 .../org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java
 
b/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java
index f3859191e4c..70f568ee904 100644
--- 
a/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java
+++ 
b/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java
@@ -50,6 +50,8 @@ import java.util.regex.Pattern;
 
 import javax.crypto.SecretKey;
 
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.LocalDirAllocator;
 import org.apache.hadoop.fs.Path;
@@ -390,6 +392,9 @@ public class ShuffleHandler implements 
AttemptRegistrationListener {
         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());