You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/06/16 09:14:42 UTC
[flink] 07/07: [hotfix][runtime] Narrow down the access scope of
SlotExecutionVertexAssignment
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 <re...@gmail.com>
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;
}
}