Fix: changed signature of ExternalShuffleClient

 Please enter the commit message for your changes. Lines starting

Author: foxish

common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/kubernetes/KubernetesExternalShuffleClient.java

@@ -47,12 +47,12 @@ public class KubernetesExternalShuffleClient extends ExternalShuffleClient {
   public KubernetesExternalShuffleClient(
       TransportConf conf,
       SecretKeyHolder secretKeyHolder,
-      boolean saslEnabled,
-      boolean saslEncryptionEnabled) {
-    super(conf, secretKeyHolder, saslEnabled, saslEncryptionEnabled);
+      boolean saslEnabled) {
+    super(conf, secretKeyHolder, saslEnabled);
   }
 
-  public void registerDriverWithShuffleService(String host, int port) throws IOException {
+  public void registerDriverWithShuffleService(String host, int port)
+      throws IOException, InterruptedException {
     checkInit();
     ByteBuffer registerDriver = new RegisterDriver(appId, 0).toByteBuffer();
     TransportClient client = clientFactory.createClient(host, port);

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/kubernetes/KubernetesClusterSchedulerBackend.scala

@@ -279,8 +279,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
     new KubernetesExternalShuffleClient(
       SparkTransportConf.fromSparkConf(conf, "shuffle"),
       sc.env.securityManager,
-      sc.env.securityManager.isAuthenticationEnabled(),
-      sc.env.securityManager.isSaslEncryptionEnabled())
+      sc.env.securityManager.isAuthenticationEnabled())
   }
 
   private def getInitialTargetExecutorNumber(defaultNumExecutors: Int = 1): Int = {

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/kubernetes/submit/KubernetesExternalShuffleServiceSuite.scala

@@ -35,7 +35,6 @@ private[spark] class KubernetesExternalShuffleServiceSuite extends SparkFunSuite
     val shuffleClient = new KubernetesExternalShuffleClient(
       SparkTransportConf.fromSparkConf(SPARK_CONF, "shuffle"),
       new SecurityManager(SPARK_CONF),
-      false,
       false)
 
     shuffleService.start()