[
https://issues.apache.org/jira/browse/FLINK-23792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410458#comment-17410458
]
Dian Fu commented on FLINK-23792:
---------------------------------
I found the following error message
{code}
Traceback (most recent call last):
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/runpy.py", line 194,
in _run_module_as_main
Aug 14 23:18:04 E return _run_code(code, main_globals,
None,
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/runpy.py", line 87, in
_run_code
Aug 14 23:18:04 E exec(code, run_globals)
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_boot.py", line 100, in
<module>
Aug 14 23:18:04 E call([python_exec, "-m",
"pyflink.fn_execution.beam.beam_sdk_worker_main"],
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/subprocess.py", line
340, in call
Aug 14 23:18:04 E with Popen(*popenargs, **kwargs) as p:
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/subprocess.py", line
858, in __init__
Aug 14 23:18:04 E self._execute_child(args, executable,
preexec_fn, close_fds,
Aug 14 23:18:04 E File
"/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/subprocess.py", line
1639, in _execute_child
Aug 14 23:18:04 E self.pid = _posixsubprocess.fork_exec(
Aug 14 23:18:04 E OSError: [Errno 12] Cannot allocate memory
{code}
It should be caused by environment issues that there is no enough memory left
on the test machine. Just close it for now as it only occurred once.
> Python test_udf.py fail on azure
> --------------------------------
>
> Key: FLINK-23792
> URL: https://issues.apache.org/jira/browse/FLINK-23792
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.0
> Reporter: Xintong Song
> Assignee: Huang Xingbo
> Priority: Major
> Labels: test-stability
> Fix For: 1.14.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22196&view=logs&j=ff2e2ea5-07e3-5521-7b04-a4fc3ad765e9&t=1ec6382b-bafe-5817-63ae-eda7d4be718e&l=24542
> {code}
> Aug 14 23:18:04 =================================== FAILURES
> ===================================
> Aug 14 23:18:04 _______________
> PyFlinkStreamUserDefinedFunctionTests.test_open ________________
> Aug 14 23:18:04
> Aug 14 23:18:04 self =
> <pyflink.table.tests.test_udf.PyFlinkStreamUserDefinedFunctionTests
> testMethod=test_open>
> Aug 14 23:18:04
> Aug 14 23:18:04 def test_open(self):
> Aug 14 23:18:04
> self.t_env.get_config().get_configuration().set_string('python.metric.enabled',
> 'true')
> Aug 14 23:18:04 subtract = udf(Subtract(),
> result_type=DataTypes.BIGINT())
> Aug 14 23:18:04 table_sink = source_sink_utils.TestAppendSink(
> Aug 14 23:18:04 ['a', 'b'], [DataTypes.BIGINT(),
> DataTypes.BIGINT()])
> Aug 14 23:18:04 self.t_env.register_table_sink("Results", table_sink)
> Aug 14 23:18:04
> Aug 14 23:18:04 t = self.t_env.from_elements([(1, 2), (2, 5), (3,
> 4)], ['a', 'b'])
> Aug 14 23:18:04 > t.select(t.a,
> subtract(t.b)).execute_insert("Results").wait()
> Aug 14 23:18:04
> Aug 14 23:18:04 pyflink/table/tests/test_udf.py:226:
> Aug 14 23:18:04 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _
> Aug 14 23:18:04 pyflink/table/table_result.py:76: in wait
> Aug 14 23:18:04 get_method(self._j_table_result, "await")()
> Aug 14 23:18:04
> .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1285: in
> __call__
> Aug 14 23:18:04 return_value = get_return_value(
> Aug 14 23:18:04 pyflink/util/exceptions.py:146: in deco
> Aug 14 23:18:04 return f(*a, **kw)
> Aug 14 23:18:04 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
