[
https://issues.apache.org/jira/browse/FLINK-14248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14248:
----------------------------
Description:
{{LazyFromSourcesSchedulingStrategy}} now will only schedule tasks in CREATED
state.
However, the DefaultScheduler will reset failed tasks when actually restarting
them.
This makes failed tasks not able to be restarted with
{{LazyFromSourcesSchedulingStrategy}}.
We can keep {{LazyFromSourcesSchedulingStrategy}} to schedule tasks in CREATED
state in normal scheduling. And make it schedule tasks in terminal state when
trying to restart tasks.
This issue also fails some IT cases on DefaultScheduler, e.g. JobRecoveryITCase.
was:
{{LazyFromSourcesSchedulingStrategy}} now will only schedule tasks in CREATED
state.
However, the DefaultScheduler will reset failed tasks when actually restarting
them.
This makes failed tasks not able to be restarted with
{{LazyFromSourcesSchedulingStrategy}}.
We can keep {{LazyFromSourcesSchedulingStrategy}} to schedule tasks in CREATED
state in normal scheduling. And make it schedule tasks in terminal state when
trying to restart tasks.
> LazyFromSourcesSchedulingStrategy should be able to restart terminated tasks
> ----------------------------------------------------------------------------
>
> Key: FLINK-14248
> URL: https://issues.apache.org/jira/browse/FLINK-14248
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 1.10.0
> Reporter: Zhu Zhu
> Priority: Major
> Fix For: 1.10.0
>
>
> {{LazyFromSourcesSchedulingStrategy}} now will only schedule tasks in CREATED
> state.
> However, the DefaultScheduler will reset failed tasks when actually
> restarting them.
> This makes failed tasks not able to be restarted with
> {{LazyFromSourcesSchedulingStrategy}}.
> We can keep {{LazyFromSourcesSchedulingStrategy}} to schedule tasks in
> CREATED state in normal scheduling. And make it schedule tasks in terminal
> state when trying to restart tasks.
> This issue also fails some IT cases on DefaultScheduler, e.g.
> JobRecoveryITCase.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
