You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/28 03:56:00 UTC

[jira] [Created] (FLINK-28271) Add configuration options for speculative scheduler

|  ![](cid:jira-generated-image-avatar-9a5a4d69-eb48-4105-9e6b-e658d810092f) |
[Zhu Zhu](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=zhuzh)
**created** an issue  
---|---  
|  
---  
|  [Flink](https://issues.apache.org/jira/browse/FLINK) / [![Sub-
task](cid:jira-generated-image-
avatar-f713f455-2788-44d8-82c6-d87238e84503)](https://issues.apache.org/jira/browse/FLINK-28271)
[FLINK-28271](https://issues.apache.org/jira/browse/FLINK-28271)  
---  
[Add configuration options for speculative
scheduler](https://issues.apache.org/jira/browse/FLINK-28271)  
| Issue Type: |  ![Sub-task](cid:jira-generated-image-
avatar-f713f455-2788-44d8-82c6-d87238e84503) Sub-task  
---|---  
Assignee: |  Unassigned  
Components: |  Runtime / Configuration  
Created: |  28/Jun/22 03:55  
Fix Versions: |  1.16.0  
Priority: |  ![Major](cid:jira-generated-image-static-
major-09fe9709-d1f9-47e4-8dbf-2d1769c3e6bd) Major  
Reporter: |  [Zhu
Zhu](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=zhuzh)  
|

Following config options are needed for speculative scheduler:

  * jobmanager.adaptive-batch-scheduler.speculative.enabled, default to "false". It controls whether to enable speculative execution. Note that speculative execution only works with AdaptiveBatchScheduler, which requires "jobmanager.scheduler" to be set to "AdaptiveBatch".
  * jobmanager.adaptive-batch-scheduler.speculative.max-concurrent-executions, default to "2". It controls how many executions (including the original one and speculative ones) of an ExecutionVertex can execute at the same time.
  * jobmanager.adaptive-batch-scheduler.speculative.block-slow-node-duration, default to "1 min". It controls how long an identified slow node should be blocked for.

  
---  
|  |  [ ![Add Comment](cid:jira-generated-image-static-comment-
icon-03d85d66-88f1-4c78-a205-4fe4744f3fdc)
](https://issues.apache.org/jira/browse/FLINK-28271#add-comment "Add Comment")
|  [Add Comment](https://issues.apache.org/jira/browse/FLINK-28271#add-comment
"Add Comment")  
---|---  
  
|  This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9) |  |
![Atlassian logo](https://issues.apache.org/jira/images/mail/atlassian-email-
logo.png)  
---