flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4490) Decouple Slot and Instance
Date Fri, 02 Sep 2016 08:29:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15457930#comment-15457930

ASF GitHub Bot commented on FLINK-4490:

Github user tillrohrmann commented on a diff in the pull request:

    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java
    @@ -104,16 +107,17 @@ public String toString() {
     					(producerState == ExecutionState.RUNNING
     							|| producerState == ExecutionState.FINISHED)) {
    -				final Instance partitionInstance = producerSlot.getInstance();
    +				final TaskManagerLocation partitionTaskManagerLocation = producerSlot.getTaskManagerLocation();
    +				final ResourceID partitionTaskManager = partitionTaskManagerLocation.getResourceID();
    --- End diff --
    But in the future the partition might reside on a machine which was not the producer.
Thus, I guess that it's good then.

> Decouple Slot and Instance
> --------------------------
>                 Key: FLINK-4490
>                 URL: https://issues.apache.org/jira/browse/FLINK-4490
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Distributed Coordination
>            Reporter: Kurt Young
>             Fix For: 1.2.0
> Currently, {{Slot}} and {{Instance}} holds each other. For {{Instance}} holding {{Slot}},
it makes sense because it reflects how many resources it can provide and how many are using.

> But it's not very necessary for {{Slot}} to hold {{Instance}} which it belongs to. It
only needs to hold some connection information and gateway to talk to. Another downside for
{{Slot}} holding {{Instance}} is that {{Instance}} actually contains some allocate/de-allocation
logicals, it will be difficult if we want to do some allocation refactor without letting {{Slot}}
> We should abstract the connection information of {{Instance}} to let {{Slot}} holds.
(Actually we have {{InstanceConnectionInfo}} now, but lacks of instance's akka gateway, maybe
we can just adding the akka gateway to the {{InstanceConnectionInfo}})

This message was sent by Atlassian JIRA

View raw message