Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
An error is thrown when tests run in parallel for interactive modules.
>google.api_core.exceptions.MethodNotImplemented: 501 Received http2 header with status: 404
The cause is shared global singleton among tests: a cluster related test registers a cluster manager in the global state while a non-cluster test cleans up the global state without necessary mocking.
The solution should be mock the global singleton in tests to isolate tests from each other.
To reproduce the failure (note: parallel execution is non-deterministic), add something like '-n 5' when executing pytests.
For example:
>pytest -n 5 apache_beam/runners/interactive/interactive_runner_test.py
Attachments
Issue Links
- is a child of
-
BEAM-14332 Improve the workflow of cluster management for Flink on Dataproc
- Resolved
- links to