This is an automated email from the ASF dual-hosted git repository.
zabetak pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/calcite.git
The following commit(s) were added to refs/heads/master by this push:
new 7e3abc5 [CALCITE-4587] Set "spark.driver.bindAddress" explicitly to
avoid "BindException" thrown by Spark (Jiatao Tao)
7e3abc5 is described below
commit 7e3abc5d67e907acd4d99f61380b521c8c1f5856
Author: Jiatao Tao <[email protected]>
AuthorDate: Fri Apr 16 16:00:25 2021 +0800
[CALCITE-4587] Set "spark.driver.bindAddress" explicitly to avoid
"BindException" thrown by Spark (Jiatao Tao)
---
.../main/java/org/apache/calcite/adapter/spark/SparkHandlerImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 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
index 975bf77..ba318ce 100644
--- 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.runtime.ArrayBindable;
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 @@ import java.util.concurrent.atomic.AtomicInteger;
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 {
