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)
