Andrey Zagrebin created FLINK-20261: ---------------------------------------
Summary: Uncaught exception in ExecutorNotifier due to split assignment broken by failed task Key: FLINK-20261 URL: https://issues.apache.org/jira/browse/FLINK-20261 Project: Flink Issue Type: Bug Components: Connectors / FileSystem Affects Versions: 1.12.0 Reporter: Andrey Zagrebin While trying to extend FileSourceTextLinesITCase::testContinuousTextFileSource with recovery test after TM failure (TestingMiniCluster::terminateTaskExecutor, [branch|https://github.com/azagrebin/flink/tree/FLINK-20118-it]), I encountered the following case: * SourceCoordinatorContext::assignSplits schedules async assignment (all reader tasks alive) * call TestingMiniCluster::terminateTaskExecutor while doing writeFile in a loop of testContinuousTextFileSource * causes graceful TaskExecutor::onStop shutdown * causes TM/RM disconnect and failing slot allocations in JM by RM * eventually causes SourceCoordinatorContext::unregisterSourceReader * actual assignment starts (SourceCoordinatorContext::assignSplits: callInCoordinatorThread) * registeredReaders.containsKey(subtaskId) check fails with IllegalArgumentException which is uncaught in single thread executor * forces ThreadPool to recreate the single thread * calls CoordinatorExecutorThreadFactory::newThread * fails expected condition of single thread creation with IllegalStateException which is uncaught * calls FatalExitExceptionHandler and exits JVM abruptly -- This message was sent by Atlassian Jira (v8.3.4#803005)