[Feature] Jupyter ecosystem support on kuberay about kuberay HOT 4 CLOSED

2024-07-03 17:07:49,676	INFO worker.py:1586 -- Connecting to existing Ray cluster at address: 127.0.0.1:8265...
---------------------------------------------------------------------------
RuntimeError                              Traceback (most recent call last)
File ~/Documents/test/ray_fashion_mnist_example/venv/lib/python3.11/site-packages/ray/_private/worker.py:1727, in init(address, num_cpus, num_gpus, resources, labels, object_store_memory, local_mode, ignore_reinit_error, include_dashboard, dashboard_host, dashboard_port, job_config, configure_logging, logging_level, logging_format, logging_config, log_to_driver, namespace, runtime_env, storage, **kwargs)
   1726 try:
-> 1727     _global_node = ray._private.node.Node(
   1728         ray_params,
   1729         head=False,
   1730         shutdown_at_exit=False,
   1731         spawn_reaper=False,
   1732         connect_only=True,
   1733     )
   1734 except (ConnectionError, RuntimeError):

File ~/Documents/test/ray_fashion_mnist_example/venv/lib/python3.11/site-packages/ray/_private/node.py:159, in Node.__init__(self, ray_params, head, shutdown_at_exit, spawn_reaper, connect_only, default_worker, ray_init_cluster)
    158     self.validate_ip_port(self.address)
--> 159     self._init_gcs_client()
    161 # Register the temp dir.

File ~/Documents/test/ray_fashion_mnist_example/venv/lib/python3.11/site-packages/ray/_private/node.py:765, in Node._init_gcs_client(self)
    764     else:
--> 765         raise RuntimeError(
    766             f"Failed to {'start' if self.head else 'connect to'} GCS."
    767         )
    769 ray.experimental.internal_kv._initialize_internal_kv(self._gcs_client)

RuntimeError: Failed to connect to GCS.

During handling of the above exception, another exception occurred:

ConnectionError                           Traceback (most recent call last)
Cell In[6], line 1
----> 1 ray.init("localhost:8265")

File ~/Documents/test/ray_fashion_mnist_example/venv/lib/python3.11/site-packages/ray/_private/client_mode_hook.py:103, in client_mode_hook.<locals>.wrapper(*args, **kwargs)
    101     if func.__name__ != "init" or is_client_mode_enabled_by_default:
    102         return getattr(ray, func.__name__)(*args, **kwargs)
--> 103 return func(*args, **kwargs)

File ~/Documents/test/ray_fashion_mnist_example/venv/lib/python3.11/site-packages/ray/_private/worker.py:1743, in init(address, num_cpus, num_gpus, resources, labels, object_store_memory, local_mode, ignore_reinit_error, include_dashboard, dashboard_host, dashboard_port, job_config, configure_logging, logging_level, logging_format, logging_config, log_to_driver, namespace, runtime_env, storage, **kwargs)
   1735         if gcs_address == ray._private.utils.read_ray_address(_temp_dir):
   1736             logger.info(
   1737                 "Failed to connect to the default Ray cluster address at "
   1738                 f"{gcs_address}. This is most likely due to a previous Ray "
   (...)
   1741                 "`ray start`."
   1742             )
-> 1743         raise ConnectionError
   1745 # Log a message to find the Ray address that we connected to and the
   1746 # dashboard URL.
   1747 if ray_constants.RAY_OVERRIDE_DASHBOARD_URL in os.environ:

ConnectionError: 

kubectl port-forward service/xxxx-head-svc 10001:10001

ray.init("ray://localhost:10001")