THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
In each ExecutionJobVertex there is a speculative execution thread used for detect the long tail execution in this ExecutionJobVertex periodically based on above three rules.
todo..
Manage input and output of each ExecutionVertex
Manage InputSplit
Manage sink files
Manage middle ResultPartition
Limitations
Configuration
Compatibility, Deprecation, and Migration Plan
...