[
https://issues.apache.org/jira/browse/FLINK-38602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang closed FLINK-38602.
-----------------------------
Fix Version/s: 2.2.0
Resolution: Fixed
master: 9fcb46e79e2f7d5ea69d03b9f2247dd2d58594b1
> 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
> Fix For: 2.2.0
>
>
> 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)
