Zakelly opened a new pull request, #25858:
URL: https://github.com/apache/flink/pull/25858
## What is the purpose of the change
#25802 introduces three test harnesses for async state processing. However,
when there is a failure on any async thread, the test thread itself will keep
`get()` the future result. This PR exposes the inner exception to the future
and make the test fast fail with root cause print.
## Brief change log
- Make the `MockEnvironment` accept any external exception. The configure
goes in the constructor of three test harnesses.
- Let any execution of task thread check the env exception, as well as
check the exception after. (Only after is not enough since the task and test
thread runs in parallel).
## Verifying this change
This change added tests and can be verified manually: throws exception in
the `triggerAction` of `EpochManager#onNonRecord` and see if there is any
exception in test.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
