Zhijiang Wang created FLINK-5830:
Summary: OutOfMemoryError during notify final state in
TaskExecutor may cause job stuck
Key: FLINK-5830
URL: https://issues.apache.org/jira/browse/FLINK-5830
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867126#comment-15867126
]
Zhijiang Wang commented on FLINK-5799:
--
This fix is useful and the {{HeartbeatManagerSenderImpl}} can
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867126#comment-15867126
]
Zhijiang Wang edited comment on FLINK-5799 at 2/15/17 2:56 AM:
---
This fix is
[
https://issues.apache.org/jira/browse/FLINK-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867116#comment-15867116
]
Zhijiang Wang commented on FLINK-5798:
--
That is good, and the heartbeat manager component can reuse
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5133:
-
Summary: Support to set resource for operator in DataStream and DataSet
(was: Add new
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5501:
Assignee: shuai.xu (was: Zhijiang Wang)
> Determine whether the job starts from last
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5703:
Assignee: Zhijiang Wang (was: shuai.xu)
> ExecutionGraph recovery based on reconciliation
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5703:
Assignee: (was: Zhijiang Wang)
> ExecutionGraph recovery based on reconciliation with
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5703:
Assignee: shuai.xu
> ExecutionGraph recovery based on reconciliation with TaskManager
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860543#comment-15860543
]
Zhijiang Wang commented on FLINK-5132:
--
Thank you, [~StephanEwen]. Yeah, it also makes sense to check
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5703:
-
Description:
The ExecutionGraph structure would be recovered from TaskManager reports during
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5703:
-
Description:
The ExecutionGraph structure would be recovered from TaskManager reports during
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5703:
-
Description:
The ExecutionGraph structure would be recovered from TaskManager reports during
Zhijiang Wang created FLINK-5703:
Summary: ExecutionGraph recovery based on reconciliation with
TaskManager reports
Key: FLINK-5703
URL: https://issues.apache.org/jira/browse/FLINK-5703
Project:
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827892#comment-15827892
]
Zhijiang Wang commented on FLINK-4364:
--
[~till.rohrmann], I closed the previous pull request for this
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827361#comment-15827361
]
Zhijiang Wang edited comment on FLINK-5501 at 1/18/17 8:42 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827361#comment-15827361
]
Zhijiang Wang edited comment on FLINK-5501 at 1/18/17 3:16 AM:
---
Thank you
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827361#comment-15827361
]
Zhijiang Wang commented on FLINK-5501:
--
Thank you for the quick response!
Yeah, you already
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5501:
-
Description:
When the {{JobManagerRunner}} grants leadership, it should check whether the
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5501:
-
Description:
When the {{JobManagerRunner}} grants leadership, it should check whether the
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5501:
Assignee: Zhijiang Wang
> Determine whether the job starts from last JobManager failure
>
Zhijiang Wang created FLINK-5501:
Summary: Determine whether the job starts from last JobManager
failure
Key: FLINK-5501
URL: https://issues.apache.org/jira/browse/FLINK-5501
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5499:
Assignee: Zhijiang Wang
> Try to reuse the resource location of prior execution attempt in
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Description: Currently when schedule execution to request to allocate slot
from {{SlotPool}}, the
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Description: Currently when schedule execution to request to allocate slot
from {{SlotPool}}, the
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Summary: Try to reuse the resource location of prior execution attempt in
allocating slot (was:
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Summary: Try to reuse the resource location of prior execution attempt when
allocate slot (was:
Zhijiang Wang created FLINK-5499:
Summary: Try to reuse the resource location of previous execution
attempt when allocate slot
Key: FLINK-5499
URL: https://issues.apache.org/jira/browse/FLINK-5499
[
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
[
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
[
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
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-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
[
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
[
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-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
[
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
[
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
[
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-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
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
[
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
[
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:
[
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
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/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
[
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
[
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
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-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
[
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
[
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
[
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
[
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
[
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
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:
[
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
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-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
[
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
[
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
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:
[
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
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-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650576#comment-15650576
]
Zhijiang Wang commented on FLINK-4364:
--
Hi [~till.rohrmann], for the heartbeat interaction between TM
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646297#comment-15646297
]
Zhijiang Wang commented on FLINK-4354:
--
Actually the current {{HeartbeatManagerImpl}} can work and be
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:46 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:44 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:41 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643637#comment-15643637
]
Zhijiang Wang commented on FLINK-4354:
--
Hi [~till.rohrmann], for heartbeat interaction between TM and
[
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: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:comment-tabpanel=15607630#comment-15607630
]
Zhijiang Wang commented on FLINK-4911:
--
Hi Stephan, the sub-tasks 2 and 3 are the same, do you mind I
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15607336#comment-15607336
]
Zhijiang Wang commented on FLINK-4911:
--
FLINK-3539 tries to realize eventual consistency between JM
[
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-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-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-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534797#comment-15534797
]
Zhijiang Wang edited comment on FLINK-4715 at 9/30/16 2:31 AM:
---
Yes, we
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534797#comment-15534797
]
Zhijiang Wang commented on FLINK-4715:
--
Yes, we already experienced this problem in real production
[
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-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4505:
-
Description: Implement {{TaskManagerRunner}} to construct related
components ({{MemoryManager}},
[
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:
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 TaskManagerFactory to bring up TaskManager for different
modes (was:
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438621#comment-15438621
]
Zhijiang Wang commented on FLINK-4489:
--
Does it refer to the slot manager in {{ResourceManager}} or
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438609#comment-15438609
]
Zhijiang Wang commented on FLINK-4354:
--
Yes, so it would be started after flink-4478 done.
>
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15434680#comment-15434680
]
Zhijiang Wang commented on FLINK-4424:
--
The previous way of {{NetworkEnvironment}} is like lazy
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15427951#comment-15427951
]
Zhijiang Wang commented on FLINK-4363:
--
Thank you Till, I got your meaning. I will follow 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-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424183#comment-15424183
]
Zhijiang Wang commented on FLINK-4021:
--
got it, i will modify the return and add the test to PR
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424056#comment-15424056
]
Zhijiang Wang commented on FLINK-4363:
--
For yarn and standalone mode, the entrance methods for
[
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
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15423994#comment-15423994
]
Zhijiang Wang commented on FLINK-4021:
--
Yeah, you are right. It is no problem in current flink
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15423984#comment-15423984
]
Zhijiang Wang commented on FLINK-4021:
--
Thank you for advice, it is indeed simple by 'return
[
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
[
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-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
1 - 100 of 133 matches
Mail list logo
