Skip to content

Commit

Permalink
[FLINK-32136][python] Fix the issue that Pyflink gateway server launc…
Browse files Browse the repository at this point in the history
…h fails when purelib != platlib

This closes apache#22802.
  • Loading branch information
dianfu committed Jun 17, 2023
1 parent 4624cc4 commit f64563b
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions flink-python/pyflink/java_gateway.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,8 @@

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

Expand Down Expand Up @@ -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

Expand Down

0 comments on commit f64563b

Please sign in to comment.