[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423984#comment-15423984
]
Zhijiang Wang commented on FLINK-4021:
--
Thank you for advice, it is indeed simple by
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423994#comment-15423994
]
Zhijiang Wang commented on FLINK-4021:
--
Yeah, you are right. It is no problem in curr
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4355:
Assignee: Stephan Ewen (was: Zhijiang Wang)
> Implement TaskManager side of registration a
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424056#comment-15424056
]
Zhijiang Wang commented on FLINK-4363:
--
For yarn and standalone mode, the entrance me
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424183#comment-15424183
]
Zhijiang Wang commented on FLINK-4021:
--
got it, i will modify the return and add the
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4363:
Assignee: Zhijiang Wang
> Implement TaskManager basic startup of all components in java
> -
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15427951#comment-15427951
]
Zhijiang Wang commented on FLINK-4363:
--
Thank you Till, I got your meaning. I will fo
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434680#comment-15434680
]
Zhijiang Wang commented on FLINK-4424:
--
The previous way of {{NetworkEnvironment}} is
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438609#comment-15438609
]
Zhijiang Wang commented on FLINK-4354:
--
Yes, so it would be started after flink-4478
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438621#comment-15438621
]
Zhijiang Wang commented on FLINK-4489:
--
Does it refer to the slot manager in {{Resou
Zhijiang Wang created FLINK-4505:
Summary: Implement abstract TaskManagerFactory to bring up
TaskManager for different modes
Key: FLINK-4505
URL: https://issues.apache.org/jira/browse/FLINK-4505
Proje
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4505:
-
Summary: Implement TaskManagerFactory to bring up TaskManager for different
modes (was: Implement
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4505:
Assignee: Zhijiang Wang
> Implement TaskManagerFactory to bring up TaskManager for differen
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438745#comment-15438745
]
Zhijiang Wang commented on FLINK-4363:
--
Hi [~mxm], I have created the FLINK-4505 for
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4505:
-
Summary: Implement TaskManagerRunner to construct related components for
TaskManager (was: Implem
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4505:
-
Description: Implement {{TaskManagerRunner}} to construct related
components ({{MemoryManager}}, {
Zhijiang Wang created FLINK-5131:
Summary: Fine-grained Resource Configuration
Key: FLINK-5131
URL: https://issues.apache.org/jira/browse/FLINK-5131
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
Zhijiang Wang created FLINK-5132:
Summary: Introduce the ResourceSpec for grouping different
resource factors in API
Key: FLINK-5132
URL: https://issues.apache.org/jira/browse/FLINK-5132
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5132:
-
Description:
This is part of the fine-grained resource configuration.
The current resource factors
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5132:
-
Description:
This is part of the fine-grained resource configuration.
The current resource factor
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
Zhijiang Wang created FLINK-5133:
Summary: Add new setResource API for DataStream and DataSet
Key: FLINK-5133
URL: https://issues.apache.org/jira/browse/FLINK-5133
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5133:
-
Description:
This is part of the fine-grained resource configuration.
For *DataStream*, the *setR
Zhijiang Wang created FLINK-5134:
Summary: Aggregate ResourceSpe for chained operators when
generating stream graph
Key: FLINK-5134
URL: https://issues.apache.org/jira/browse/FLINK-5134
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description: In datastream API,
> Aggregate ResourceSpe for chained operators when generating stre
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Summary: Aggregate ResourceSpe for chained operators when generating job
graph (was: Aggregate Re
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description: In DataStream API, the *ResourceSpec* is setted onto the
internal transformation (wa
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description:
In *JobGraph* generation, each *JobVertex* corresponds to a series of chained
operat
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description:
In *JobGraph* generation, each *JobVertex* corresponds to a series of chained
operat
Zhijiang Wang created FLINK-5135:
Summary: ResourceProfile should be expanded to correspond with
ResourceSpec
Key: FLINK-5135
URL: https://issues.apache.org/jira/browse/FLINK-5135
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5135:
-
Summary: ResourceProfile for slot request should be expanded to correspond
with ResourceSpec (was
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5135:
-
Description: The *JobManager* requests slot by *ResourceProfile* from
*ResourceManager* before sub
Zhijiang Wang created FLINK-5136:
Summary: ResourceManager should consider both slot resource
profile and framework memory for requesting resource from cluster
Key: FLINK-5136
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Summary: Aggregation of slot ResourceProfile and framework memory for
requesting resource from clu
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Summary: Aggregation of slot ResourceProfile and framework memory by
ResourceManager (was: Aggreg
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Description:
When *ResourceManager* requests container resource from cluster, the framework
memor
Zhijiang Wang created FLINK-5137:
Summary: Config JVM options and set onto the TaskManager container
Key: FLINK-5137
URL: https://issues.apache.org/jira/browse/FLINK-5137
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5137:
-
Description: The users can config JVM options in job level. And the
*ResourceManager* will set rel
[
https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5137:
Assignee: Zhijiang Wang
> Config JVM options and set onto the TaskManager container
> -
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5136:
Assignee: Zhijiang Wang
> Aggregation of slot ResourceProfile and framework memory by Resou
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5135:
Assignee: Zhijiang Wang
> ResourceProfile for slot request should be expanded to correspond
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5132:
Assignee: Zhijiang Wang
> Introduce the ResourceSpec for grouping different resource factor
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5134:
Assignee: Zhijiang Wang
> Aggregate ResourceSpe for chained operators when generating job g
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5133:
Assignee: Zhijiang Wang
> Add new setResource API for DataStream and DataSet
>
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
Zhijiang Wang created FLINK-5138:
Summary: The StateBackend provides the method to estimate memory
usage based on hint of state size in ResourceSpec
Key: FLINK-5138
URL: https://issues.apache.org/jira/browse/FLINK
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5138:
-
Component/s: Core
> The StateBackend provides the method to estimate memory usage based on hint
>
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5138:
-
Description:
Users may specify the state size in *setResource* API, then the different
*StateBack
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5138:
Assignee: Zhijiang Wang
> The StateBackend provides the method to estimate memory usage bas
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405484#comment-15405484
]
Zhijiang Wang commented on FLINK-4256:
--
In further improvement, if task c failed, the
Zhijiang Wang created FLINK-4354:
Summary: TaskManager to ResourceManager heartbeats
Key: FLINK-4354
URL: https://issues.apache.org/jira/browse/FLINK-4354
Project: Flink
Issue Type: Sub-task
Zhijiang Wang created FLINK-4355:
Summary: TaskManager registration at ResourceManager
Key: FLINK-4355
URL: https://issues.apache.org/jira/browse/FLINK-4355
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Assignee: (was: Zhijiang Wang)
> TaskManager to ResourceManager heartbeats
> -
Zhijiang Wang created FLINK-4357:
Summary: TaskManager responses slot allocation
Key: FLINK-4357
URL: https://issues.apache.org/jira/browse/FLINK-4357
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Description: RM initiates Heartbeat with ResourceManagerLeaderID. TM
responses to RM with slot all
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Summary: TaskManager responses heartbeats from ResourceManager (was:
TaskManager responses Resour
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: TaskManager responses slot allocation from ResourceManager (was:
TaskManager responses s
Zhijiang Wang created FLINK-4358:
Summary: TaskManager deploys task into slot
Key: FLINK-4358
URL: https://issues.apache.org/jira/browse/FLINK-4358
Project: Flink
Issue Type: Sub-task
Zhijiang Wang created FLINK-4360:
Summary: TaskManager slot registration at JobManager
Key: FLINK-4360
URL: https://issues.apache.org/jira/browse/FLINK-4360
Project: Flink
Issue Type: Sub-tas
Zhijiang Wang created FLINK-4363:
Summary: TaskManager basic startup of all components
Key: FLINK-4363
URL: https://issues.apache.org/jira/browse/FLINK-4363
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4363:
Assignee: Zhijiang Wang
> TaskManager basic startup of all components
> ---
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Assignee: (was: Zhijiang Wang)
> TaskManager basic startup of all components
> ---
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Assignee: Zhijiang Wang
> TaskManager deploys task into slot
> --
Zhijiang Wang created FLINK-4364:
Summary: TaskManage responses heartbeats from JobManager
Key: FLINK-4364
URL: https://issues.apache.org/jira/browse/FLINK-4364
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Description:
The {{ResourceManager}} initiates heartbeat messages via the {{RmLeaderID}}.
The {{T
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4354:
Assignee: Zhijiang Wang
> TaskManager responses heartbeats from ResourceManager
> -
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Summary: Implement TaskManager side of heartbeat from ResourceManager
(was: TaskManager response
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: Implement TaskManager side slot allocation from ResourceManager
(was: TaskManager respon
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: Implement TaskManager side of slot allocation from ResourceManager
(was: Implement TaskM
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4355:
-
Summary: Implement TaskManager side of registration at ResourceManager
(was: TaskManager registra
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Summary: Implement TaskManager deployment task into slot (was: TaskManager
deploys task into slot
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Description:
The {{TaskManager}} may receive task deployment request (bound to
slot/allocationID)
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Summary: Implement TaskManager offer slot to JobManager (was: TaskManager
slot registration at Jo
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Description: The {{TaskManager}} offers a slot to a {{JobManager}} at the
{{ResourceManager}}’s be
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Summary: Implement TaskManager registration slot at JobManager (was:
Implement TaskManager offer
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Summary: Implement TaskManager basic startup of all components in java
(was: TaskManager basic st
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Description: Similar with current {{TaskManager}},but implement
initialization and startup all com
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Summary: Implement TaskManager side of heartbeats from JobManager (was:
TaskManage responses hear
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Summary: Implement TaskManager side of heartbeat from JobManager (was:
Implement TaskManager side
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4360:
Assignee: Zhijiang Wang
> Implement TaskManager registration slot at JobManager
> -
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4357:
Assignee: Zhijiang Wang
> Implement TaskManager side of slot allocation from ResourceManage
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Description: The {{JobManager}} initiates heartbeat messages via (JobID,
JmLeaderID), and the {{Ta
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang closed FLINK-4505.
> Implement TaskManagerRunner to construct related components for TaskManager
>
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534797#comment-15534797
]
Zhijiang Wang commented on FLINK-4715:
--
Yes, we already experienced this problem in r
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534797#comment-15534797
]
Zhijiang Wang edited comment on FLINK-4715 at 9/30/16 2:31 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4914:
Assignee: Zhijiang Wang
> Define parameters for reconciliation
> --
[
https://issues.apache.org/jira/browse/FLINK-4915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4915:
Assignee: Zhijiang Wang
> Define parameters for reconciliation
> --
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4912:
Assignee: Zhijiang Wang
> Introduce RECONCILING state in ExecutionGraph
> -
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607336#comment-15607336
]
Zhijiang Wang commented on FLINK-4911:
--
FLINK-3539 tries to realize eventual consiste
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607630#comment-15607630
]
Zhijiang Wang commented on FLINK-4911:
--
Hi Stephan, the sub-tasks 2 and 3 are the sam
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4911:
Assignee: Zhijiang Wang
> Non-disruptive JobManager Failures via Reconciliation
>
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4911:
-
Component/s: TaskManager
> Non-disruptive JobManager Failures via Reconciliation
> --
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611247#comment-15611247
]
Zhijiang Wang commented on FLINK-4911:
--
Yeah, it does "at-least once".
BTW, I confi
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643637#comment-15643637
]
Zhijiang Wang commented on FLINK-4354:
--
Hi [~till.rohrmann], for heartbeat interactio
1 - 100 of 135 matches
Mail list logo
