You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/09 09:45:33 UTC

[flink] branch release-1.14 updated (a5fcaec -> 2f8f217e)

This is an automated email from the ASF dual-hosted git repository.

mapohl pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a5fcaec  [FLINK-26543][python] Fix the issue that exceptions generated during startup are lost in Python loopback mode
     add 2f8f217e [FLINK-23843][runtime] Properly fail the job when SplitEnumeratorContext.runInCoordinatorThread() throws an exception.

No new revisions were added by this update.

Summary of changes:
 .../coordinator/SourceCoordinatorContext.java      | 11 ++++++-
 .../coordinator/SourceCoordinatorProvider.java     | 23 +++++++++-----
 .../MockOperatorCoordinatorContext.java            |  8 +++++
 .../coordinator/SourceCoordinatorContextTest.java  | 35 +++++++++++++++++++++-
 .../coordinator/SourceCoordinatorTestBase.java     |  2 +-
 5 files changed, 69 insertions(+), 10 deletions(-)