[jira] [Created] (FLINK-26745) Unable to create new env

["Rahul Desai (Jira)" <ji...@apache.org>]

Rahul Desai created FLINK-26745:
-----------------------------------

             Summary: Unable to create new env
                 Key: FLINK-26745
                 URL: https://issues.apache.org/jira/browse/FLINK-26745
             Project: Flink
          Issue Type: Bug
          Components: API / Python
    Affects Versions: 1.14.4, 1.14.3
         Environment: Below is the Error log

FileNotFoundError Traceback (most recent call last) Input In [10], in <cell line: 1>() ----> 1 env = EnvironmentSettings.new_instance().build()  2 table_env = TableEnvironment.create(env) File D:\Anaconda3\envs\pyflink_env\lib\site-packages\pyflink\table\environment_settings.py:241, in EnvironmentSettings.new_instance()  231 @staticmethod  232 def new_instance() -> 'EnvironmentSettings.Builder':  233 """  234 Creates a builder for creating an instance of EnvironmentSettings.  235  (...)  239 :return: A builder of EnvironmentSettings.  240 """ --> 241 return EnvironmentSettings.Builder() File D:\Anaconda3\envs\pyflink_env\lib\site-packages\pyflink\table\environment_settings.py:51, in EnvironmentSettings.Builder.__init__(self)  50 def __init__(self): ---> 51 gateway = get_gateway()  52 self._j_builder = gateway.jvm.EnvironmentSettings.Builder() File D:\Anaconda3\envs\pyflink_env\lib\site-packages\pyflink\java_gateway.py:62, in get_gateway()  57 _gateway = JavaGateway(  58 gateway_parameters=gateway_param,  59 callback_server_parameters=CallbackServerParameters(  60 port=0, daemonize=True, daemonize_connections=True))  61 else: ---> 62 _gateway = launch_gateway()  64 callback_server = _gateway.get_callback_server()  65 callback_server_listening_address = callback_server.get_listening_address() File D:\Anaconda3\envs\pyflink_env\lib\site-packages\pyflink\java_gateway.py:106, in launch_gateway()  103 env = dict(os.environ)  104 env["_PYFLINK_CONN_INFO_PATH"] = conn_info_file --> 106 p = launch_gateway_server_process(env, args)  108 while not p.poll() and not os.path.isfile(conn_info_file):  109 time.sleep(0.1) File D:\Anaconda3\envs\pyflink_env\lib\site-packages\pyflink\pyflink_gateway_server.py:304, in launch_gateway_server_process(env, args)  302 signal.signal(signal.SIGINT, signal.SIG_IGN)  303 preexec_fn = preexec_func --> 304 return Popen(list(filter(lambda c: len(c) != 0, command)),  305 stdin=PIPE, preexec_fn=preexec_fn, env=env) File D:\Anaconda3\envs\pyflink_env\lib\subprocess.py:858, in Popen.__init__(self, args, bufsize, executable, stdin, stdout, stderr, preexec_fn, close_fds, shell, cwd, env, universal_newlines, startupinfo, creationflags, restore_signals, start_new_session, pass_fds, encoding, errors, text)  854 if self.text_mode:  855 self.stderr = io.TextIOWrapper(self.stderr,  856 encoding=encoding, errors=errors) --> 858 self._execute_child(args, executable, preexec_fn, close_fds,  859 pass_fds, cwd, env,  860 startupinfo, creationflags, shell,  861 p2cread, p2cwrite,  862 c2pread, c2pwrite,  863 errread, errwrite,  864 restore_signals, start_new_session)  865 except:  866 # Cleanup if the child failed starting.  867 for f in filter(None, (self.stdin, self.stdout, self.stderr)): File D:\Anaconda3\envs\pyflink_env\lib\subprocess.py:1311, in Popen._execute_child(self, args, executable, preexec_fn, close_fds, pass_fds, cwd, env, startupinfo, creationflags, shell, p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite, unused_restore_signals, unused_start_new_session)  1309 # Start the process  1310 try: -> 1311 hp, ht, pid, tid = _winapi.CreateProcess(executable, args,  1312 # no special security  1313 None, None,  1314 int(not close_fds),  1315 creationflags,  1316 env,  1317 cwd,  1318 startupinfo)  1319 finally:  1320 # Child is launched. Close the parent's copy of those pipe  1321 # handles that only the child should have open. You need  (...)  1324 # pipe will not close when the child process exits and the  1325 # ReadFile will hang.  1326 self._close_pipe_fds(p2cread, p2cwrite,  1327 c2pread, c2pwrite,  1328 errread, errwrite) FileNotFoundError: [WinError 2] The system cannot find the file specified
            Reporter: Rahul Desai


I'm getting "File not found error" while creating environment/table environment in Pyflink. It was working fine a few days before but since today I'm facing this issue. Below are a few steps which I tried to fix it.
 # update packages/downgraded package
 # created new env
 # reinstalled the package



--
This message was sent by Atlassian Jira
(v8.20.1#820001)