rkhachatryan opened a new pull request, #27634:
URL: https://github.com/apache/flink/pull/27634
Confirmed the root cause by adding wait in TM
```
while (task.getExecutionState() == ExecutionState.RUNNING) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
```
to `TaskExecutor.sendOperatorEventToTask` after
[this](https://github.com/apache/flink/blob/2db7996c95fd02eafc59c0dfd08ad9f726170266/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java#L1430)
line
(not included in the commit).
Explanation:
```
// Fail SideOutputITCase.testWatermarkForwarding.
// The test source is about to finish (it emits just one record before
END_OF_INPUT),
// and any attempt to deliver an event to a FINISHED task fails the job.
// However, usually it's delivered while the task is still RUNNING; or it
finishes before
// the RPC starts - so the executor on JM is shut down before delivery
attempt.
// Here, we deliberately wait for the task to FINISH to fail the test:
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
