[
https://issues.apache.org/jira/browse/BEAM-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-8103 started by null.
----------------------------------
> Stop job service when pipeline execution finishes
> -------------------------------------------------
>
> Key: BEAM-8103
> URL: https://issues.apache.org/jira/browse/BEAM-8103
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Kyle Weaver
> Priority: P3
> Labels: portability-flink
>
> Currently, job servers are shut down when the Python script exits [1]. A
> better long-term solution would be to shut them down instead when the
> pipeline is finished executing, such as [2]. This will put resource
> management in a common code path that is less error-prone.
>
> [1]
> [https://github.com/apache/beam/blob/c5f43342f914fc8ff367b86fb9294c38436ed3ce/sdks/python/apache_beam/runners/portability/job_server.py#L73]
> [2]
> [https://github.com/apache/beam/blob/c5f43342f914fc8ff367b86fb9294c38436ed3ce/sdks/python/apache_beam/runners/portability/portable_runner.py#L451]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
