0

我正在使用 PyCharm 运行简单的 pyflink 最新 1.13 示例（它只有两行）。但该get_gateway()方法不起作用。

对于解释器，我创建了虚拟环境并在我的 PyCharm 项目中使用它。我还下载了Java8。我尝试了很多步骤来解决这个问题，但是

from pyflink.common.serialization import Encoder
from pyflink.common.typeinfo import Types
from pyflink.datastream import StreamExecutionEnvironment
from pyflink.datastream.connectors import StreamingFileSink
def print_hi(name):
    # Use a breakpoint in the code line below to debug your script.
    print(f'Hi, {name}')  # Press Ctrl+F8 to toggle the breakpoint.
    env = StreamExecutionEnvironment.get_execution_environment()
    env.set_parallelism(1)

C:\Users\myuser\AppData\Local\Programs\Python\Python38\myvenv\Scripts\python.exe C:/Users/myuser/PycharmProjects/pythonProject3/main.py
Hi, PyCharm
Traceback (most recent call last):
  File "C:/Users/myuser/PycharmProjects/pythonProject3/main.py", line 19, in <module>
    print_hi('PyCharm')
  File "C:/Users/myuser/PycharmProjects/pythonProject3/main.py", line 13, in print_hi
    env = StreamExecutionEnvironment.get_execution_environment()
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\myvenv\lib\site-packages\pyflink\datastream\stream_execution_environment.py", line 688, in get_execution_environment
    gateway = get_gateway()
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\myvenv\lib\site-packages\pyflink\java_gateway.py", line 62, in get_gateway
    _gateway = launch_gateway()
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\myvenv\lib\site-packages\pyflink\java_gateway.py", line 106, in launch_gateway
    p = launch_gateway_server_process(env, args)
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\myvenv\lib\site-packages\pyflink\pyflink_gateway_server.py", line 221, in launch_gateway_server_process
    return Popen(command, stdin=PIPE, preexec_fn=preexec_fn, env=env)
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\lib\subprocess.py", line 858, in __init__
    self._execute_child(args, executable, preexec_fn, close_fds,
  File "C:\Users\myuser\AppData\Local\Programs\Python\Python38\lib\subprocess.py", line 1311, in _execute_child
    hp, ht, pid, tid = _winapi.CreateProcess(executable, args,
FileNotFoundError: [WinError 2] The system cannot find the file specified
4

0 回答 0