diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotTracker.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotTracker.java index 16f203613e15c..4ddeb5211979f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotTracker.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotTracker.java @@ -185,7 +185,7 @@ private void transitionSlotToAllocated(DeclarativeTaskManagerSlot slot, JobID jo Preconditions.checkNotNull(slot); Preconditions.checkState( jobId.equals(slot.getJobId()), - "Job ID from slot status updated (%s) does not match currently assigned job ID (%s) for slot %s.", + "Job ID from slot status update (%s) does not match currently assigned job ID (%s) for slot %s.", jobId, slot.getJobId(), slot.getSlotId());