[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7378:
Description:
Currently the number of network buffers in {{LocalBufferPool}} for
{{SingleInputGate}} is limi
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7378:
Summary: Create a fix size (non rebalancing) buffer pool type for the
floating buffers (was: Implement the
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&focusedCommentId=16116017#comment-16116017
]
zhijiang commented on FLINK-7377:
-
repeated in [FLINK-7378|https://issues.apache.org/jira/
[
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
Is
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
[FLIP|ht
[
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
[FLIP|ht
[
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
[FLIP|ht
[
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
[FLIP|ht
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
Compo
[
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&focusedCommentId=16079979#comment-16079979
]
zhijiang commented on FLINK-6161:
-
[~till.rohrmann], would you mind assigning this issue t
[
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&focusedCommentId=15983189#comment-15983189
]
zhijiang commented on FLINK-6337:
-
Yeah, I got your point. Thank you for check and advice
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982574#comment-15982574
]
zhijiang edited comment on FLINK-6337 at 4/25/17 9:20 AM:
--
Hey [~
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982574#comment-15982574
]
zhijiang commented on FLINK-6337:
-
Thank you for so quick response!
Currently the buffer
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982534#comment-15982534
]
zhijiang commented on FLINK-6337:
-
[~uce], do you think it makes sense to remove the buffe
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 Type
[
https://issues.apache.org/jira/browse/FLINK-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15974401#comment-15974401
]
zhijiang commented on FLINK-6325:
-
[~StephanEwen], for specific implementation, we would l
[
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 prior
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: Improvement
[
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
Issue
[
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
{{DEFAULT_SLOT_REQUEST_T
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932773#comment-15932773
]
zhijiang commented on FLINK-4545:
-
[~StephanEwen], Yeah, there are two cases, first is for
[
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 ta
[
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 b
[
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 heartbea
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 Ty
[
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&focusedCommentId=15931247#comment-15931247
]
zhijiang commented on FLINK-4545:
-
[~StephanEwen], thank you for so rich information!
I a
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929676#comment-15929676
]
zhijiang edited comment on FLINK-4545 at 3/17/17 9:58 AM:
--
[~Nico
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929676#comment-15929676
]
zhijiang commented on FLINK-4545:
-
[~NicoK], [~StephanEwen], thank you for your replies!
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 Ty
[
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 heartbea
[
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 heartbea
[
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 heartbea
[
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 si
[
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 payloads
[
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 payloads
[
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 h
[
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 e
[
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 e
[
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: Add
[
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 e
[
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: Cor
[
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, eac
[
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 ResourceSpe
[
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 the
[
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 the
[
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
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 - 1163 of 1163 matches
Mail list logo
