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

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: statefun-2.0.0
• Fix Version/s: statefun-2.0.0
• Component/s: Stateful Functions
• Labels: pull-request-available
• Assignee: Igal Shilman
• Reporter: Tzu-Li (Gordon) Tai
• Created: 01/Apr/20 16:03
• Updated: 02/Apr/20 17:06
• Resolved: 02/Apr/20 17:06

Description

The following exception is being thrown indefinitely once a worker is lost:

org.apache.flink.util.FlinkException: Multi task slot is not local and, thus, does not fulfill the co-location constraint.

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.

Issue Links

• relates to: FLINK-16928 Switch back to new scheduler in Stateful Functions
• links to: GitHub Pull Request #91