This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 812e674 [FLINK-26504][python] Fix the incorrect type error in
unbounded Python UDAF
add c4cafa3 [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(-)
