[FLINK-17297] Log the lineage information between ExecutionAttemptID …

…and SlotRequestID This closes apache#11850.
spotify · Jun 23, 2020 · d45a5f0 · d45a5f0
1 parent 380fddf
commit d45a5f0
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -542,16 +542,18 @@ private CompletableFuture<LogicalSlot> allocateAndAssignSlotForExecution(
 
  final CompletableFuture<LogicalSlot> logicalSlotFuture =
  preferredLocationsFuture.thenCompose(
- (Collection<TaskManagerLocation> preferredLocations) ->
- slotProviderStrategy.allocateSlot(
+ (Collection<TaskManagerLocation> preferredLocations) -> {
+ LOG.info("Allocating slot with SlotRequestID {} for the execution attempt {}.", slotRequestId, attemptId);
+ return slotProviderStrategy.allocateSlot(
  slotRequestId,
  toSchedule,
  SlotProfile.priorAllocation(
  vertex.getResourceProfile(),
  getPhysicalSlotResourceProfile(vertex),
  preferredLocations,
  previousAllocationIDs,
- allPreviousExecutionGraphAllocationIds)));
+ allPreviousExecutionGraphAllocationIds));
+ });
 
  // register call back to cancel slot request in case that the execution gets canceled
  releaseFuture.whenComplete(