This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0aea300ccf23780221bd9d628511b698a0aa519b Author: Zhu Zhu <[email protected]> AuthorDate: Tue Jun 16 00:03:55 2020 +0800 [hotfix][runtime] Narrow down the access scope of SlotExecutionVertexAssignment --- .../flink/runtime/scheduler/SlotExecutionVertexAssignment.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotExecutionVertexAssignment.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotExecutionVertexAssignment.java index b52c6af..a25209f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotExecutionVertexAssignment.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotExecutionVertexAssignment.java @@ -29,24 +29,24 @@ import static org.apache.flink.util.Preconditions.checkNotNull; /** * The slot assignment for a {@link ExecutionVertex}. */ -public class SlotExecutionVertexAssignment { +class SlotExecutionVertexAssignment { private final ExecutionVertexID executionVertexId; private final CompletableFuture<LogicalSlot> logicalSlotFuture; - public SlotExecutionVertexAssignment( + SlotExecutionVertexAssignment( ExecutionVertexID executionVertexId, CompletableFuture<LogicalSlot> logicalSlotFuture) { this.executionVertexId = checkNotNull(executionVertexId); this.logicalSlotFuture = checkNotNull(logicalSlotFuture); } - public ExecutionVertexID getExecutionVertexId() { + ExecutionVertexID getExecutionVertexId() { return executionVertexId; } - public CompletableFuture<LogicalSlot> getLogicalSlotFuture() { + CompletableFuture<LogicalSlot> getLogicalSlotFuture() { return logicalSlotFuture; } }
