[flink] branch release-1.16 updated: [FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.16 by this push:
     new f9394025fb7 [FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib
f9394025fb7 is described below

commit f9394025fb756c844ec5f2615971f227d40b9244
Author: Dian Fu <di...@apache.org>
AuthorDate: Fri Jun 16 13:21:14 2023 +0800

    [FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib
    
    This closes #22802.
---
 flink-python/pyflink/java_gateway.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/flink-python/pyflink/java_gateway.py b/flink-python/pyflink/java_gateway.py
index 4bd1c3c858e..a7be4d24f91 100644
--- a/flink-python/pyflink/java_gateway.py
+++ b/flink-python/pyflink/java_gateway.py
@@ -27,6 +27,8 @@ from threading import RLock
 
 from py4j.java_gateway import (java_import, logger, JavaGateway, GatewayParameters,
                                CallbackServerParameters)
+
+from pyflink.find_flink_home import _find_flink_home
 from pyflink.pyflink_gateway_server import launch_gateway_server_process
 from pyflink.util.exceptions import install_exception_handler, install_py4j_hooks
 
@@ -100,6 +102,8 @@ def launch_gateway():
         os.close(fd)
         os.unlink(conn_info_file)
 
+        _find_flink_home()
+
         env = dict(os.environ)
         env["_PYFLINK_CONN_INFO_PATH"] = conn_info_file