0

按照链接描述的stackOverflow链接上的脚本，从某种意义上说，数据的唯一变化我想评估pyflink的简单用法，以分析它的安装是否有效。您可以在系统下方和为了安装它，我使用 pip -m install apache-flink 进入带有 python3.8.4 的虚拟环境。为了安装 flink 本身，我使用了 docker 并导入了 pyflink/playgrounds:1.10.0 的图像。下面是我修改的链接中唯一的部分

source_ddl = """
                CREATE TABLE MyUserTable (
                        column_a INT,
                        column_b INT,
                        
                        ) WITH (
                          'connector' = 'filesystem',         
                          'path' = 'file:///Users//code/examples/input.csv ', 
                          'format' = 'csv'

                        )"""


#connector for data output/sink
sink_ddl = """
                CREATE TABLE results (
                            score INT)
                            WITH (
                                'connector' = 'filesystem',
                                'path' = 'file:///Users//code/examples/output.csv',
                                'format' = 'csv'
                            )"""

#make the table corresponding to the schema mentioned
source_table = table_env.execute_sql(source_ddl)
sink_table = table_env.execute_sql(sink_ddl)

#convert the sql table to table API
table_path = table_env.from_path("MyUserTable")

# execute SELECT statement
table_result2 = table_env.execute_sql("SELECT column_a FROM MyUserTable")
table_result2.print()

错误如下：

Traceback (most recent call last):
  File ".\flink1.py", line 15, in <module>
    env_settings = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build()
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\lib\site-packages\pyflink\table\environment_settings.py", line 214, in new_instance
    return EnvironmentSettings.Builder()
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\lib\site-packages\pyflink\table\environment_settings.py", line 48, in __init__
    gateway = get_gateway()
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\lib\site-packages\pyflink\java_gateway.py", line 62, in get_gateway
    _gateway = launch_gateway()
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\lib\site-packages\pyflink\java_gateway.py", line 106, in launch_gateway
    p = launch_gateway_server_process(env, args)
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\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\landr\AppData\Local\Programs\Python\Python38\lib\subprocess.py", line 854, in __init__
    self._execute_child(args, executable, preexec_fn, close_fds,
  File "C:\Users\landr\AppData\Local\Programs\Python\Python38\lib\subprocess.py", line 1307, in _execute_child   
    hp, ht, pid, tid = _winapi.CreateProcess(executable, args,
FileNotFoundError: [WinError 2] Impossibile trovare il file specificato
4

0 回答 0