diff --git a/dask_databricks/cli.py b/dask_databricks/cli.py index 2d8008f..0651ca5 100644 --- 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 index 535673c..54b1b03 100644 --- 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():