[
https://issues.apache.org/jira/browse/FLINK-26745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rahul Desai updated FLINK-26745:
--------------------------------
Attachment: Error_log.txt
> 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.3, 1.14.4
> 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
> Priority: Major
> Attachments: Error_log.txt
>
>
> 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)
