[CALCITE-4587] Set "spark.driver.bindAddress" explicitly to avoid "Bi…

…ndException" thrown by Spark (Jiatao Tao)
apache · Apr 19, 2021 · 7e3abc5 · 7e3abc5
1 parent 8169246
commit 7e3abc5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/spark/src/main/java/org/apache/calcite/adapter/spark/SparkHandlerImpl.java b/spark/src/main/java/org/apache/calcite/adapter/spark/SparkHandlerImpl.java
@@ -27,6 +27,7 @@
 import org.apache.calcite.util.Util;
 import org.apache.calcite.util.javac.JaninoCompiler;
 
+import org.apache.spark.SparkConf;
 import org.apache.spark.api.java.JavaSparkContext;
 
 import java.io.File;
@@ -44,8 +45,10 @@
 public class SparkHandlerImpl implements CalcitePrepare.SparkHandler {
   private final HttpServer classServer;
   private final AtomicInteger classId;
+  private final SparkConf sparkConf =
+      new SparkConf().set("spark.driver.bindAddress", "localhost");
   private final JavaSparkContext sparkContext =
-      new JavaSparkContext("local[1]", "calcite");
+      new JavaSparkContext("local[1]", "calcite", sparkConf);
 
   /** Thread-safe holder. */
   private static class Holder {