zhijiang created FLINK-7416:
---
Summary: Implement Netty receiver outgoing pipeline for
credit-based
Key: FLINK-7416
URL: https://issues.apache.org/jira/browse/FLINK-7416
Project: Flink
Issue Type:
zhijiang created FLINK-7406:
---
Summary: Implement Netty receiver incoming pipeline for
credit-based
Key: FLINK-7406
URL: https://issues.apache.org/jira/browse/FLINK-7406
Project: Flink
Issue Type:
zhijiang created FLINK-7394:
---
Summary: Implement basic InputChannel for credit-based logic
Key: FLINK-7394
URL: https://issues.apache.org/jira/browse/FLINK-7394
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116017#comment-16116017
]
zhijiang commented on FLINK-7377:
-
repeated in
[
https://issues.apache.org/jira/browse/FLINK-7377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7377.
---
Resolution: Duplicate
> Implement FixedBufferPool for floating buffers in SingleInputGate
>
zhijiang created FLINK-7378:
---
Summary: Implement the FixedBufferPool for floating buffers of
SingleInputGate
Key: FLINK-7378
URL: https://issues.apache.org/jira/browse/FLINK-7378
Project: Flink
zhijiang created FLINK-7377:
---
Summary: Implement FixedBufferPool for floating buffers in
SingleInputGate
Key: FLINK-7377
URL: https://issues.apache.org/jira/browse/FLINK-7377
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
zhijiang created FLINK-7282:
---
Summary: Credit-based Network Flow Control
Key: FLINK-7282
URL: https://issues.apache.org/jira/browse/FLINK-7282
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-6161:
---
Assignee: zhijiang
> Retry connection in case of a ResourceManager heartbeat timeout
>
[
https://issues.apache.org/jira/browse/FLINK-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079979#comment-16079979
]
zhijiang commented on FLINK-6161:
-
[~till.rohrmann], would you mind assigning this issue to me? I am
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-4449:
---
Assignee: jingzhang (was: zhijiang)
> Heartbeat Manager integration with TaskExecutor
>
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-4449:
---
Assignee: zhijiang (was: jingzhang)
> Heartbeat Manager integration with TaskExecutor
>
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983189#comment-15983189
]
zhijiang commented on FLINK-6337:
-
Yeah, I got your point. Thank you for check and advice, my friend!
>
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982574#comment-15982574
]
zhijiang edited comment on FLINK-6337 at 4/25/17 9:20 AM:
--
Hey [~uce], Thank you
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982574#comment-15982574
]
zhijiang commented on FLINK-6337:
-
Thank you for so quick response!
Currently the buffer provider only
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982534#comment-15982534
]
zhijiang commented on FLINK-6337:
-
[~uce], do you think it makes sense to remove the buffer provider from
zhijiang created FLINK-6337:
---
Summary: Remove the buffer provider from
PartitionRequestServerHandler
Key: FLINK-6337
URL: https://issues.apache.org/jira/browse/FLINK-6337
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974401#comment-15974401
]
zhijiang commented on FLINK-6325:
-
[~StephanEwen], for specific implementation, we would like to add a
[
https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-6325:
---
Assignee: zhijiang
> Refinement of slot reuse for task manager failure
>
[
https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6325:
Description:
After task or TaskManager failure, the new execution attempt tries to take the
slot from
zhijiang created FLINK-6325:
---
Summary: Refinement of slot reuse for task manager failure
Key: FLINK-6325
URL: https://issues.apache.org/jira/browse/FLINK-6325
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-6227:
---
Assignee: zhijiang
> Introduce the DataConsumptionException for downstream task failure
>
zhijiang created FLINK-6227:
---
Summary: Introduce the DataConsumptionException for downstream
task failure
Key: FLINK-6227
URL: https://issues.apache.org/jira/browse/FLINK-6227
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-4354.
---
> Implement heartbeat logic between TaskManager and ResourceManager
>
[
https://issues.apache.org/jira/browse/FLINK-6095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6095:
Description:
Currently all the parameters in {{SlotPool}} are hard coded including
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932773#comment-15932773
]
zhijiang commented on FLINK-4545:
-
[~StephanEwen], Yeah, there are two cases, first is for all task
[
https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6120:
Description:
It is part of work for Flip-6.
The HeartbeatManager is mainly used for monitoring heartbeat
[
https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6120:
Summary: Implement heartbeat logic between JobManager and ResourceManager
(was: Implement heartbeat logic
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4354:
Description:
It is part of work for Flip-6.
The {{HeartbeatManager}} is mainly used for monitoring
zhijiang created FLINK-6120:
---
Summary: Implement heartbeat logic between JobMaster and
ResourceManager
Key: FLINK-6120
URL: https://issues.apache.org/jira/browse/FLINK-6120
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-4364.
---
> Implement heartbeat logic between TaskManager and JobManager
>
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931247#comment-15931247
]
zhijiang commented on FLINK-4545:
-
[~StephanEwen], thank you for so rich information!
I agree with the
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929676#comment-15929676
]
zhijiang edited comment on FLINK-4545 at 3/17/17 9:58 AM:
--
[~NicoK],
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929676#comment-15929676
]
zhijiang commented on FLINK-4545:
-
[~NicoK], [~StephanEwen], thank you for your replies!
As I know, we
zhijiang created FLINK-6095:
---
Summary: Introduce the SlotPoolOptions to config parameters for
SlotPool
Key: FLINK-6095
URL: https://issues.apache.org/jira/browse/FLINK-6095
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4354:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4354:
Summary: Implement heartbeat logic between TaskManager and ResourceManager
(was: Implement TaskManager
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
The {{HeartbeatManager}} is mainly used for monitoring heartbeat target and
reporting
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
The {{HeartbeatManager}} is mainly used for monitoring heartbeat target and
reporting
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Summary: Implement heartbeat logic between TaskManager and JobManager
(was: Implement TaskManager side of
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Description:
Users may specify the state size in {{setResources}} API, then the state
backend would
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Description:
Users may specify the state size in *setResources* API, then the state backend
would roughly
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Description:
Users may specify the state size in *setResources* API, then the state backend
would roughly
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Summary: Add the method in state backend to estimate memory by hint of
state size in ResourceSpec (was:
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Description:
Users may specify the state size in *setResources* API, then the state backend
would roughly
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Summary: Add the interface in state backend to estimate memory by hint of
state size in ResourceSpec (was:
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5138:
Component/s: (was: DataStream API)
(was: DataSet API)
(was:
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Description:
This is a part of fine-grained resource configuration in flip-6.
In *JobGraph* generation,
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Summary: Aggregate ResourceSpec for chained operators when generating job
graph (was: Aggregate
[
https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5893:
Description:
The map of {{JobManagerRegistration}} in ResourceManager is not thread-safe,
and currently
[
https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-5893:
---
Assignee: zhijiang
> Race condition in removing previous JobManagerRegistration in ResourceManager
>
[
https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5893:
Description:
The map of {{JobManagerRegistration}} in ResourceManager is not thread-safe,
and currently
[
https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5893:
Description:
The map of {{JobManagerRegistration}} in {{ResourceManager}} is not
thread-safe, and
zhijiang created FLINK-5893:
---
Summary: Race condition in removing previous
JobManagerRegistration in ResourceManager
Key: FLINK-5893
URL: https://issues.apache.org/jira/browse/FLINK-5893
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-5830:
---
Assignee: zhijiang
> OutOfMemoryError during notify final state in TaskExecutor may cause job stuck
1101 - 1161 of 1161 matches
Mail list logo
