From 62ae925af514d8974b2a56066704c3ebcf53bf3d Mon Sep 17 00:00:00 2001 From: Oz Ben-Ami Date: Mon, 15 Jan 2018 19:02:25 +0000 Subject: [PATCH] allow Spark Thrift Server to run in Kubernetes Cluster mode --- core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala index 1e381965c52b..71e33f231786 100644 --- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala +++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala @@ -328,7 +328,7 @@ object SparkSubmit extends CommandLineUtils with Logging { printErrorAndExit("Cluster deploy mode is not applicable to Spark shells.") case (_, CLUSTER) if isSqlShell(args.mainClass) => printErrorAndExit("Cluster deploy mode is not applicable to Spark SQL shell.") - case (_, CLUSTER) if isThriftServer(args.mainClass) => + case (_, CLUSTER) if (clusterManager != KUBERNETES) && isThriftServer(args.mainClass) => printErrorAndExit("Cluster deploy mode is not applicable to Spark Thrift server.") case _ => }