diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java index 867203c15c604..26f3a13a0365f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java @@ -112,7 +112,7 @@ public TaskSlotTable( } /** - * Start the task slot table with the given slot actions and slot timeout value. + * Start the task slot table with the given slot actions. * * @param initialSlotActions to use for slot actions */ @@ -182,7 +182,7 @@ public SlotReport createSlotReport(ResourceID resourceId) { /** * Allocate the slot with the given index for the given job and allocation id. Returns true if - * the slot could be allocated. Otherwise it returns false; + * the slot could be allocated. Otherwise it returns false. * * @param index of the task slot to allocate * @param jobId to allocate the task slot for