Avoid Ray port and just use 8087

dask-contrib · Nov 8, 2023 · 3cd7750 · 3cd7750
1 parent 59eb2d9
commit 3cd7750
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dask_databricks/cli.py b/dask_databricks/cli.py
@@ -38,7 +38,7 @@ def run():
 
     if DB_IS_DRIVER == "TRUE":
         log.info("This node is the Dask scheduler.")
-        subprocess.Popen(["dask", "scheduler", "--dashboard-address", ":8787,:8265,:8087,:8001"])
+        subprocess.Popen(["dask", "scheduler", "--dashboard-address", ":8787,:8087"])
     else:
         log.info("This node is a Dask worker.")
         log.info(f"Connecting to Dask scheduler at {DB_DRIVER_IP}:8786")

diff --git a/dask_databricks/databrickscluster.py b/dask_databricks/databrickscluster.py
@@ -45,7 +45,7 @@ def dashboard_link(self):
             raise RuntimeError("Unable to locate spark session. Are you running this on a Databricks driver node?")
         cluster_id = spark.conf.get("spark.databricks.clusterUsageTags.clusterId")
         org_id = spark.conf.get("spark.databricks.clusterUsageTags.orgId")
-        return f"https://dbc-dp-{org_id}.cloud.databricks.com/driver-proxy/o/{org_id}/{cluster_id}/8265/status"
+        return f"https://dbc-dp-{org_id}.cloud.databricks.com/driver-proxy/o/{org_id}/{cluster_id}/8087/status"
 
 
 def get_client():