This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1ff23ac [FLINK-25851][cassandra][tests] Inject dynamic table name
into Pojos
new 89046bc [FLINK-24607] Let Deadline handle duration overflow.
new 6936ce6 [FLINK-24607] Add util methods to shutdown executor services.
new 0a76d63 [FLINK-24607] Make OperatorCoordinator closure more robust.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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
