[Distributed runtime] Send failIntermediateResultPartitions(ExecutionAttemptID) RPC calls from JM to TMs when a finished task is cancelled
[Tests] Fix JobMangerITCase.testTwoInputJobFailingEdgeMismatch
[Distributed runtime] Various changes for robustness
Lock partition access to avoid race with asynchronous resourceReleaseCalls [ci skip]