Toggle navigation
Home
org.apache.flink.runtime.clusterframework.types.AllocationID to org.apache.flink.runtime.taskexecutor.slot.SlotOffer
No. of Instances - 6
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
AllocationID
to
SlotOffer
AllocationID
to
SlotOffer
AllocationID
to
SlotOffer
Iterable<AllocationID>
to
Iterable<SlotOffer>
AllocationID
to
SlotOffer
Cascading Type Change (Different)
Iterable<AllocationID>
to
Iterable<SlotOffer>
AcceptFunction<Iterable<AllocationID>>
to
AcceptFunction<Iterable<SlotOffer>>
AcceptFunction<Iterable<AllocationID>>
to
AcceptFunction<Iterable<SlotOffer>>
Add or Remove Method invocation
taskSlotTable.markSlotActive(acceptedSlot)
to
taskSlotTable.markSlotActive(acceptedSlot.getAllocationId())
jobMasterGateway.failSlot(acceptedSlot,leaderId,new Exception(message))
to
jobMasterGateway.failSlot(getResourceID(),acceptedSlot.getAllocationId(),leaderId,new Exception(message))
jobMasterGateway.failSlot(acceptedSlot,leaderId,e)
to
jobMasterGateway.failSlot(getResourceID(),acceptedSlot.getAllocationId(),leaderId,e)
freeSlot(rejectedSlot,e)
to
freeSlot(rejectedSlot.getAllocationId(),e)
freeSlot(reservedSlot,throwable)
to
freeSlot(reservedSlot.getAllocationId(),throwable)
taskSlotTable.markSlotActive(acceptedSlot)
to
taskSlotTable.markSlotActive(acceptedSlot.getAllocationId())
jobMasterGateway.failSlot(acceptedSlot,leaderId,new Exception(message))
to
jobMasterGateway.failSlot(getResourceID(),acceptedSlot.getAllocationId(),leaderId,new Exception(message))
jobMasterGateway.failSlot(acceptedSlot,leaderId,e)
to
jobMasterGateway.failSlot(getResourceID(),acceptedSlot.getAllocationId(),leaderId,e)
freeSlot(rejectedSlot,e)
to
freeSlot(rejectedSlot.getAllocationId(),e)
freeSlot(reservedSlot,throwable)
to
freeSlot(reservedSlot.getAllocationId(),throwable)