[jira] [Created] (FLINK-16927) Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16927) Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler

Shang Yuanchun (Jira)
Tzu-Li (Gordon) Tai created FLINK-16927:
-------------------------------------------

             Summary: Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler
                 Key: FLINK-16927
                 URL: https://issues.apache.org/jira/browse/FLINK-16927
             Project: Flink
          Issue Type: Bug
          Components: Stateful Functions
    Affects Versions: statefun-2.0.0
            Reporter: Tzu-Li (Gordon) Tai
            Assignee: Tzu-Li (Gordon) Tai


The following exception is being thrown indefinitely once a worker is lost:
{code}
org.apache.flink.util.FlinkException: Multi task slot is not local and, thus, does not fulfill the co-location constraint.
{code}

This is caused by FLINK-16139, which is fixed in Flink 1.10.1.

To unblock the release for Stateful Functions 2.0.0, which depends on Flink 1.10.0,
for StateFun 2.0.0 we can use the old legacy scheduler for the time being.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)