Details
-
Sub-task
-
Status: Closed
-
Blocker
-
Resolution: Done
-
None
-
None
Description
This task aims to verify FLINK-30707 which improves the slow task detection.
The slow task detection now takes the input data volume of tasks into account. Tasks which has a longer execution time but consumes more data may not be considered as slow. This improvement helps to eliminate the negative impacts of data skew on slow task detecting.
The documentation of speculative execution can be found here .
One can verify it by creating intended data skew.