You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/12/01 09:09:00 UTC

[jira] [Updated] (FLINK-30258) PyFlink supports closing loop back server

     [ https://issues.apache.org/jira/browse/FLINK-30258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xuannan Su updated FLINK-30258:
-------------------------------
    Description: 
Currently, a loopback server will be started whenever a StreamExecutionEnvironment or StreamTableEnvironment is created. The loopback server can only be closed after the process exit. This might not be a problem for regular uses where only one environment object is used.

However, when running tests, such as the unit tests for PyFlink itself, as the environment objects are created, the process starts more and more loopback servers and takes more and more resources.

Therefore, we want to support closing the loopback server.

  was:
Currently, a loopback server will be started whenever a StreamExecutionEnvironment or StreamTableEnvironment is created. The loopback server can only be closed after the process exit. This might not be a problem for regular uses where only one environment object is used.

However, when running tests, such as the unit tests for PyFlink itself, as the environment objects are created, the process starts more and more loopback servers and takes more and more resources.


> PyFlink supports closing loop back server
> -----------------------------------------
>
>                 Key: FLINK-30258
>                 URL: https://issues.apache.org/jira/browse/FLINK-30258
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / Python
>    Affects Versions: 1.16.0
>            Reporter: Xuannan Su
>            Priority: Major
>
> Currently, a loopback server will be started whenever a StreamExecutionEnvironment or StreamTableEnvironment is created. The loopback server can only be closed after the process exit. This might not be a problem for regular uses where only one environment object is used.
> However, when running tests, such as the unit tests for PyFlink itself, as the environment objects are created, the process starts more and more loopback servers and takes more and more resources.
> Therefore, we want to support closing the loopback server.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)