[
https://issues.apache.org/jira/browse/FLINK-38602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-38602:
----------------------------
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=70612&view=logs&j=3e4dd1a2-fe2f-5e5d-a581-48087e718d53&t=b524639c-eabb-5d4b-da24-554e98ef4a3d
{code}
Caused by: java.lang.RuntimeException: Failed to create stage bundle
factory! INFO:root:Initializing Python harness:
/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_boot.py --id=2-1
--provision_endpoint=localhost:45683
Oct 31 03:53:16 E INFO:root:Starting up Python harness in a
standalone process.
Oct 31 03:53:16 E Traceback (most recent call last):
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/runpy.py",
line 197, in _run_module_as_main
Oct 31 03:53:16 E return _run_code(code, main_globals,
None,
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/runpy.py",
line 87, in _run_code
Oct 31 03:53:16 E exec(code, run_globals)
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_boot.py", line 121, in
<module>
Oct 31 03:53:16 E from pyflink.fn_execution.beam import
beam_sdk_worker_main
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py", line
24, in <module>
Oct 31 03:53:16 E import
pyflink.fn_execution.beam.beam_operations # noqa # pylint: disable=unused-import
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations.py", line 29,
in <module>
Oct 31 03:53:16 E import
pyflink.fn_execution.beam.beam_operations_slow as beam_operations
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line
30, in <module>
Oct 31 03:53:16 E from
pyflink.fn_execution.datastream.process.async_function.operation import
AsyncOperation
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py",
line 62, in <module>
Oct 31 03:53:16 E class ResultHandler(ResultFuture,
Generic[IN, OUT]):
Oct 31 03:53:16 E File
"/__w/2/s/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py",
line 66, in ResultHandler
Oct 31 03:53:16 E timeout_func: Callable[[IN,
ResultFuture[[OUT]]], None],
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
line 277, in inner
Oct 31 03:53:16 E return func(*args, **kwds)
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
line 993, in __class_getitem__
Oct 31 03:53:16 E params = tuple(_type_check(p, msg) for
p in params)
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
line 993, in <genexpr>
Oct 31 03:53:16 E params = tuple(_type_check(p, msg) for
p in params)
Oct 31 03:53:16 E File
"/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
line 166, in _type_check
Oct 31 03:53:16 E raise TypeError(f"{msg} Got
{arg!r:.100}.")
Oct 31 03:53:16 E TypeError: Parameters to generic types must
be types. Got [~OUT].
{code}
was:https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=70612&view=logs&j=3e4dd1a2-fe2f-5e5d-a581-48087e718d53&t=b524639c-eabb-5d4b-da24-554e98ef4a3d
> test_cron_adaptive_scheduler python failed
> ------------------------------------------
>
> Key: FLINK-38602
> URL: https://issues.apache.org/jira/browse/FLINK-38602
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 2.2.0
> Reporter: Ruan Hang
> Assignee: Dian Fu
> Priority: Major
> Labels: pull-request-available
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=70612&view=logs&j=3e4dd1a2-fe2f-5e5d-a581-48087e718d53&t=b524639c-eabb-5d4b-da24-554e98ef4a3d
> {code}
> Caused by: java.lang.RuntimeException: Failed to create stage bundle
> factory! INFO:root:Initializing Python harness:
> /__w/2/s/flink-python/pyflink/fn_execution/beam/beam_boot.py --id=2-1
> --provision_endpoint=localhost:45683
> Oct 31 03:53:16 E INFO:root:Starting up Python harness in a
> standalone process.
> Oct 31 03:53:16 E Traceback (most recent call last):
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/runpy.py",
> line 197, in _run_module_as_main
> Oct 31 03:53:16 E return _run_code(code, main_globals,
> None,
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/runpy.py",
> line 87, in _run_code
> Oct 31 03:53:16 E exec(code, run_globals)
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_boot.py", line 121, in
> <module>
> Oct 31 03:53:16 E from pyflink.fn_execution.beam import
> beam_sdk_worker_main
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py",
> line 24, in <module>
> Oct 31 03:53:16 E import
> pyflink.fn_execution.beam.beam_operations # noqa # pylint:
> disable=unused-import
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations.py", line
> 29, in <module>
> Oct 31 03:53:16 E import
> pyflink.fn_execution.beam.beam_operations_slow as beam_operations
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py",
> line 30, in <module>
> Oct 31 03:53:16 E from
> pyflink.fn_execution.datastream.process.async_function.operation import
> AsyncOperation
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py",
> line 62, in <module>
> Oct 31 03:53:16 E class ResultHandler(ResultFuture,
> Generic[IN, OUT]):
> Oct 31 03:53:16 E File
> "/__w/2/s/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py",
> line 66, in ResultHandler
> Oct 31 03:53:16 E timeout_func: Callable[[IN,
> ResultFuture[[OUT]]], None],
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
> line 277, in inner
> Oct 31 03:53:16 E return func(*args, **kwds)
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
> line 993, in __class_getitem__
> Oct 31 03:53:16 E params = tuple(_type_check(p, msg)
> for p in params)
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
> line 993, in <genexpr>
> Oct 31 03:53:16 E params = tuple(_type_check(p, msg)
> for p in params)
> Oct 31 03:53:16 E File
> "/home/agent03_azpcontainer/.local/share/uv/python/cpython-3.9.23-linux-x86_64-gnu/lib/python3.9/typing.py",
> line 166, in _type_check
> Oct 31 03:53:16 E raise TypeError(f"{msg} Got
> {arg!r:.100}.")
> Oct 31 03:53:16 E TypeError: Parameters to generic types
> must be types. Got [~OUT].
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
