This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 965774c [FLINK-25851][cassandra][tests] Inject dynamic table name
into Pojos
add e2a8990 [FLINK-24607] Let Deadline handle duration overflow.
add 0774fed [FLINK-24607] Add util methods to shutdown executor services.
add 6fb7807 [FLINK-24607] Make OperatorCoordinator closure more robust.
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/api/common/time/Deadline.java | 27 +++-
.../coordination/ComponentClosingUtils.java | 95 +++++++++++-
.../RecreateOnResetOperatorCoordinator.java | 12 +-
.../source/coordinator/ExecutorNotifier.java | 21 +--
.../source/coordinator/SourceCoordinator.java | 23 +--
.../coordinator/SourceCoordinatorContext.java | 20 +--
.../coordinator/SourceCoordinatorProvider.java | 13 +-
.../coordination/ComponentClosingUtilsTest.java | 172 +++++++++++++++++++++
.../source/coordinator/ExecutorNotifierTest.java | 14 +-
.../source/coordinator/SourceCoordinatorTest.java | 62 +++++++-
.../coordinator/SourceCoordinatorTestBase.java | 9 +-
.../ManuallyTriggeredScheduledExecutorService.java | 2 +-
12 files changed, 382 insertions(+), 88 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/ComponentClosingUtilsTest.java
