Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5256#discussion_r160200089
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
---
@@ -194,8 +195,17 @@ private void scheduleAsyncDelete(StreamStateHandle
streamStateHandle) {
// We do the small optimization to not issue discards for
placeholders, which are NOPs.
if (streamStateHandle != null &&
!isPlaceholder(streamStateHandle)) {
LOG.trace("Scheduled delete of state handle {}.",
streamStateHandle);
- asyncDisposalExecutor.execute(
- new
SharedStateRegistry.AsyncDisposalRunnable(streamStateHandle));
+ AsyncDisposalRunnable asyncDisposalRunnable = new
AsyncDisposalRunnable(streamStateHandle);
+ try {
+
asyncDisposalExecutor.execute(asyncDisposalRunnable);
+ } catch (RejectedExecutionException ex) {
+ // TODO This is a temporary fix for a problem
when the ZooKeeperCompletedCheckpointStore on shutdown:
--- End diff --
typo: on --> is
---
