[jira] [Created] (FLINK-20837) Assign an increasing number larger than the numberOfSlot to dynamic slots

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

[jira] [Created] (FLINK-20837) Assign an increasing number larger than the numberOfSlot to dynamic slots

Shang Yuanchun (Jira)
Yangze Guo created FLINK-20837:
----------------------------------

             Summary: Assign an increasing number larger than the numberOfSlot to dynamic slots
                 Key: FLINK-20837
                 URL: https://issues.apache.org/jira/browse/FLINK-20837
             Project: Flink
          Issue Type: Sub-task
            Reporter: Yangze Guo
             Fix For: 1.13.0


In FLINK-14189, we specified that the SlotID whose slot number is -1 represents the dynamic slot. However, the SlotID with a negative slot number will be treated as invalid in other components, e.g. SlotPool and SlotManager. We have to remove a lot of sanity checks with this change, which is error-prone. The evidence is that there are still some sanity checks that have not been removed, e.g. sanity checks in AllocatedSlotInfo.
We propose to assign an increasing number larger than the numberOfSlot to dynamic slots. In this way, we can decouple the JM and RM with the dynamic slot logic.



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