Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-24405

parameter for python worker timeout

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Incomplete
    • 2.3.0
    • None
    • PySpark

    Description

      Currently, the python worker timeout is set to 60000 ms in code and cannot be changed. I am developing a pure python application, but workers die after 1min of inactivity. And new activity after 1min makes new python workers and sets the environment again. Can we make this parameter configurable with the default being set to 1min so that pure python applications are faster?

      parameter = "IDLE_WORKER_TIMEOUT_MS"
      file =PythonWorkerFactory.scala

      Attachments

        Activity

          People

            Unassigned Unassigned
            litup Deepansh
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: