TEZ-4399: ShuffleHandler fails with SSLHandshakeException not found w…

…hen SSL is enabled (#196) (Himanshu Mishra reviewed by Laszlo Bodor)
apache · Apr 1, 2022 · 519e31b · 519e31b
1 parent 75f753e
commit 519e31b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/DagDeleteRunnable.java b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/DagDeleteRunnable.java
@@ -54,7 +54,7 @@ public void run() {
     try {
       URL baseURL = TezRuntimeUtils.constructBaseURIForShuffleHandlerDagComplete(
           nodeId.getHost(), shufflePort,
-          dag.getApplicationId().toString(), dag.getId(), false);
+          dag.getApplicationId().toString(), dag.getId(), httpConnectionParams.isSslShuffle());
       httpConnection = TezRuntimeUtils.getHttpConnection(true, baseURL, httpConnectionParams,
           "DAGDelete", jobTokenSecretManager);
       httpConnection.connect();

diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/TaskAttemptFailedDeleteRunnable.java b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/TaskAttemptFailedDeleteRunnable.java
@@ -55,7 +55,7 @@ public void run() {
       URL baseURL = TezRuntimeUtils.constructBaseURIForShuffleHandlerTaskAttemptFailed(
           nodeId.getHost(), shufflePort, taskAttemptID.getTaskID().getVertexID().getDAGId().
               getApplicationId().toString(), taskAttemptID.getTaskID().getVertexID().getDAGId().getId(),
-          taskAttemptID.toString(), false);
+          taskAttemptID.toString(), httpConnectionParams.isSslShuffle());
       httpConnection = TezRuntimeUtils.getHttpConnection(true, baseURL, httpConnectionParams,
           "FailedTaskAttemptDelete", jobTokenSecretManager);
       httpConnection.connect();

diff --git a/tez-plugins/tez-aux-services/pom.xml b/tez-plugins/tez-aux-services/pom.xml
@@ -246,6 +246,7 @@
                   <shadedPattern>org.apache.tez.shaded.$0</shadedPattern>
                   <excludes>
                     <exclude>javax.crypto.*</exclude>
+                    <exclude>javax.net.**</exclude>
                   </excludes>
                 </relocation>
               </relocations>