Xuannan Su created FLINK-30258:
----------------------------------

             Summary: 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


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.



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

Reply via email to