Thesharing opened a new pull request #12917:
URL: https://github.com/apache/flink/pull/12917


   (仅用于预览,不会提交)
   
思路:用`slotPoolImpl.requestNewAllocatedSlot()`来代替`schedulerImpl.allocateSlot()`,在该test
 
case的最后用`logialSlot.isAlive()`来判断slot状态,而`requestNewAllocatedSlot()`返回的是`PhysicalSlot`,因此用`SingleLogicalSlot.allocateFromPhysicalSlot()`创建`LogicalSLot`,同时引入了一个空的`TestSlotOwner`(因为`allocateFromPhysicalSlot`需要`SlotOwner`)。自行跑了一下,test
 case通过,但是不确定这样做法是否正确。
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to