You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/02/08 00:38:00 UTC

[flink] 02/03: [hotfix][coordination] Clarify shared slot number & allocation ids

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 220aaa2b2d67e38261bf4da9d58df1695000a0ad
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Feb 4 13:02:21 2021 +0100

    [hotfix][coordination] Clarify shared slot number & allocation ids
---
 .../main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java
index 5ea1999..5d9a05e 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java
@@ -113,14 +113,15 @@ public interface LogicalSlot {
     CompletableFuture<?> releaseSlot(@Nullable Throwable cause);
 
     /**
-     * Gets the slot number on the TaskManager.
+     * Gets the slot number on the TaskManager. Multiple logical slots can share the same slot
+     * number.
      *
      * @return slot number
      */
     int getPhysicalSlotNumber();
 
     /**
-     * Gets the allocation id of this slot.
+     * Gets the allocation id of this slot. Multiple logical slots can share the same allocation id.
      *
      * @return allocation id of this slot
      */