[jira] [Created] (FLINK-20672) CheckpointAborted RPC failure can fail JM

["Roman Khachatryan (Jira)" <ji...@apache.org>]

Roman Khachatryan created FLINK-20672:
-----------------------------------------

             Summary: CheckpointAborted RPC failure can fail JM
                 Key: FLINK-20672
                 URL: https://issues.apache.org/jira/browse/FLINK-20672
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
    Affects Versions: 1.11.3, 1.12.0
            Reporter: Roman Khachatryan


Introduced in FLINK-8871, aborted RPC notifications are done asynchonously:
 
{code}
	private void sendAbortedMessages(long checkpointId, long timeStamp) {
		// send notification of aborted checkpoints asynchronously.
		executor.execute(() -> {
			// send the "abort checkpoint" messages to necessary vertices.
                        // ..
		});
	}
{code}

However, the executor that eventually executes this request is created as follows
{code}
		final ScheduledExecutorService futureExecutor = Executors.newScheduledThreadPool(
				Hardware.getNumberCPUCores(),
				new ExecutorThreadFactory("jobmanager-future"));
{code}

ExecutorThreadFactory uses UncaughtExceptionHandler that exits JVM on error.

cc: [~yunta]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)