diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java index 411aa94b20b4e..3db5c692da30d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java @@ -39,7 +39,7 @@ *
  • Active - The slot is in active use by a job manager which is the leader of the allocating job.
  • * * - *

    A task slot can only be allocated if it is in state free. An allocated task slot can transition + *

    A task slot can only be allocated if it is in state free. An allocated task slot can transit * to state active. * *

    An active slot allows to add tasks from the respective job and with the correct allocation id. @@ -261,7 +261,7 @@ public boolean markInactive() { } /** - * Mark the slot as free. A slot can only marked as free if it's empty. + * Mark the slot as free. A slot can only be marked as free if it's empty. * * @return True if the new state is free; otherwise false */