[FLINK-17298] Log the lineage information between SlotRequestID and A…

…llocationID This closes apache#11851.
shuttie · Jun 23, 2020 · 600b5dc · 600b5dc
1 parent d04d1f4
commit 600b5dc
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java
@@ -324,11 +324,9 @@ private void requestSlotFromResourceManager(
 		checkNotNull(resourceManagerGateway);
 		checkNotNull(pendingRequest);
 
-		log.info("Requesting new slot [{}] and profile {} from resource manager.", pendingRequest.getSlotRequestId(), pendingRequest.getResourceProfile());
-
 		final AllocationID allocationId = new AllocationID();
-
 		pendingRequest.setAllocationId(allocationId);
+
 		pendingRequests.put(pendingRequest.getSlotRequestId(), allocationId, pendingRequest);
 
 		pendingRequest.getAllocatedSlotFuture().whenComplete(
@@ -345,6 +343,9 @@ private void requestSlotFromResourceManager(
 				}
 			});
 
+		log.info("Requesting new slot [{}] and profile {} with allocation id {} from resource manager.",
+			pendingRequest.getSlotRequestId(), pendingRequest.getResourceProfile(), allocationId);
+
 		CompletableFuture<Acknowledge> rmResponse = resourceManagerGateway.requestSlot(
 			jobMasterId,
 			new SlotRequest(jobId, allocationId, pendingRequest.getResourceProfile(), jobManagerAddress),