zhijiang created FLINK-10662:
Summary: Refactor the ChannelSelector interface for single
selected channel
Key: FLINK-10662
URL: https://issues.apache.org/jira/browse/FLINK-10662
Project: Flink
zhijiang created FLINK-10661:
Summary: Initial credit should be configured in a separate
parameter
Key: FLINK-10661
URL: https://issues.apache.org/jira/browse/FLINK-10661
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10653:
-
Description:
The network shuffle behavior for batch jobs in Flink can be improved in two
dimensions:
zhijiang created FLINK-10653:
Summary: Propose of external shuffle service for batch jobs
Key: FLINK-10653
URL: https://issues.apache.org/jira/browse/FLINK-10653
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660123#comment-16660123
]
zhijiang commented on FLINK-10573:
--
I have not focused on this implement yet. If your Jira would be
[
https://issues.apache.org/jira/browse/FLINK-10607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658745#comment-16658745
]
zhijiang commented on FLINK-10607:
--
[~pnowojski], this is the issue from the review of
[
https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658744#comment-16658744
]
zhijiang edited comment on FLINK-10606 at 10/22/18 8:41 AM:
[~pnowojski],
[
https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658744#comment-16658744
]
zhijiang commented on FLINK-10606:
--
[~pnowojski], this is the issue from the review of
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658543#comment-16658543
]
zhijiang commented on FLINK-9761:
-
I just quickly reviewed the related codes and think this is still a
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658543#comment-16658543
]
zhijiang edited comment on FLINK-9761 at 10/22/18 3:56 AM:
---
I just quickly
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658496#comment-16658496
]
zhijiang commented on FLINK-10491:
--
[~till.rohrmann], I think it should be covered in FLINK-1.7 if can
[
https://issues.apache.org/jira/browse/FLINK-10607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10607:
-
Affects Version/s: (was: 1.5.6)
(was: 1.6.3)
[
https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10606:
-
Affects Version/s: (was: 1.5.6)
(was: 1.6.3)
zhijiang created FLINK-10607:
Summary: Unify to remove duplicated
NoOpResultPartitionConsumableNotifier
Key: FLINK-10607
URL: https://issues.apache.org/jira/browse/FLINK-10607
Project: Flink
zhijiang created FLINK-10606:
Summary: Construct NetworkEnvironment simple for tests
Key: FLINK-10606
URL: https://issues.apache.org/jira/browse/FLINK-10606
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16654833#comment-16654833
]
zhijiang commented on FLINK-10573:
--
I think my previous Jira
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644580#comment-16644580
]
zhijiang commented on FLINK-10367:
--
Good point!
I have not thought of returning this
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-10491:
Assignee: zhijiang
> Deadlock during spilling data in SpillableSubpartition
>
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643077#comment-16643077
]
zhijiang commented on FLINK-10491:
--
For {{SpillableSubpartition#releaseMemory}}, actually it has been
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16641481#comment-16641481
]
zhijiang commented on FLINK-10491:
--
I think we can set the {{BufferPoolOwner}} in the construction of
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16641324#comment-16641324
]
zhijiang commented on FLINK-10462:
--
[~NicoK], thanks for your feedback!
In our special cases, if many
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632808#comment-16632808
]
zhijiang commented on FLINK-10462:
--
[~pnowojski] [~NicoK] Do you have other concerns or is it necessary
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
[
https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10462:
-
Description:
Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will
be
zhijiang created FLINK-10462:
Summary: Remove ConnectionIndex for further sharing tcp connection
in credit-based mode
Key: FLINK-10462
URL: https://issues.apache.org/jira/browse/FLINK-10462
Project:
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627155#comment-16627155
]
zhijiang commented on FLINK-10367:
--
Thanks for your feedback, [~NicoK].
For the option 2, if the
[
https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623153#comment-16623153
]
zhijiang commented on FLINK-10339:
--
Hey [~NicoK] [~pnowojski], do you think we should make
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9913:
Affects Version/s: 1.5.0
1.5.1
1.5.2
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10367:
-
Description:
For task failure or canceling, the {{SingleInputGate#releaseAllResources}} will
be
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10367:
-
Description:
For task failure or canceling, the {{SingleInputGate#releaseAllResources}} will
be
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10367:
-
Description:
For task failure or canceling, the {{SingleInputGate#releaseAllResources}} will
be
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10367:
-
Description:
For task failure or canceling, the {{SingleInputGate#releaseAllResources}} will
be
zhijiang created FLINK-10367:
Summary: Avoid recursion stack overflow during releasing
SingleInputGate
Key: FLINK-10367
URL: https://issues.apache.org/jira/browse/FLINK-10367
Project: Flink
zhijiang created FLINK-10339:
Summary: SpillReadBufferPool cannot use off-heap memory
Key: FLINK-10339
URL: https://issues.apache.org/jira/browse/FLINK-10339
Project: Flink
Issue Type:
zhijiang created FLINK-10321:
Summary: Make the condition of broadcast partitioner simple
Key: FLINK-10321
URL: https://issues.apache.org/jira/browse/FLINK-10321
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602806#comment-16602806
]
zhijiang commented on FLINK-4175:
-
I am interested in this improvement and want to know what is the
[
https://issues.apache.org/jira/browse/FLINK-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582241#comment-16582241
]
zhijiang commented on FLINK-10158:
--
I already improved it in
[
https://issues.apache.org/jira/browse/FLINK-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569669#comment-16569669
]
zhijiang commented on FLINK-10047:
--
let's trace it together. :)
> Checkpointing takes much longer with
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8523:
Comment: was deleted
(was: Hey [~pnowojski], [~NicoK] Glad to see we come back to this issue again.
I
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561200#comment-16561200
]
zhijiang commented on FLINK-8523:
-
Hey [~pnowojski], [~NicoK] Glad to see we come back to this issue
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561199#comment-16561199
]
zhijiang commented on FLINK-8523:
-
Hey [~pnowojski], [~NicoK] Glad to see we come back to this issue
zhijiang created FLINK-9913:
---
Summary: Improve output serialization only once in RecordWriter
Key: FLINK-9913
URL: https://issues.apache.org/jira/browse/FLINK-9913
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524873#comment-16524873
]
zhijiang commented on FLINK-9676:
-
[~NicoK], I think this is a bug in credit-based mode.
> Deadlock
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
zhijiang created FLINK-9676:
---
Summary: Deadlock during canceling task and recycling exclusive
buffer
Key: FLINK-9676
URL: https://issues.apache.org/jira/browse/FLINK-9676
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519204#comment-16519204
]
zhijiang commented on FLINK-9636:
-
[~NicoK], I think this is a bug during implementing credit-based flow
zhijiang created FLINK-9636:
---
Summary: Network buffer leaks in requesting a batch of segments
during canceling
Key: FLINK-9636
URL: https://issues.apache.org/jira/browse/FLINK-9636
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-8747.
---
> The tag of waiting for floating buffers in RemoteInputChannel should be
> updated properly
>
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8523:
Affects Version/s: 1.6.0
> Stop assigning floating buffers for blocked input channels in exactly-once
>
[
https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429589#comment-16429589
]
zhijiang commented on FLINK-9142:
-
Yeah, this change seems more reasonable as we discussed before.(y)
>
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-7282:
---
Assignee: zhijiang
> Credit-based Network Flow Control
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8747:
Description:
In credit-based flow control mode, when the number of available buffers is less
than required
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8747:
Description:
In credit-based flow control mode, when the number of available buffers is less
than required
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8747:
Description:
In credit-based flow control mode, when the number of available buffers is less
than required
zhijiang created FLINK-8747:
---
Summary: The tag of waiting for floating buffers in
RemoteInputChannel should be updated properly
Key: FLINK-8747
URL: https://issues.apache.org/jira/browse/FLINK-8747
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8547:
Description:
Currently in exactly-once mode, the {{BarrierBuffer}} would block inputs with
barriers until
zhijiang created FLINK-8547:
---
Summary: Implement CheckpointBarrierHandler not to spill data for
exactly-once based on credit-based flow control
Key: FLINK-8547
URL: https://issues.apache.org/jira/browse/FLINK-8547
zhijiang created FLINK-8523:
---
Summary: Stop assigning floating buffers for blocked input
channels in exactly-once mode
Key: FLINK-8523
URL: https://issues.apache.org/jira/browse/FLINK-8523
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8458:
Issue Type: Sub-task (was: Task)
Parent: FLINK-7282
> Add the switch for keeping both the old mode
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8458:
Description:
After the whole feature of credit-based flow control is done, we should add a
config
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8458:
Fix Version/s: 1.5.0
> Add the switch for keeping both the old mode and the new credit-based mode
>
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-8458:
Description:
After the whole feature of credit-based flow control is done, we should add a
config
zhijiang created FLINK-8458:
---
Summary: Add the switch for keeping both the old mode and the new
credit-based mode
Key: FLINK-8458
URL: https://issues.apache.org/jira/browse/FLINK-8458
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7468.
---
Resolution: Fixed
> Implement sender backlog logic for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reopened FLINK-7456:
-
> Implement Netty sender incoming pipeline for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7456.
---
Resolution: Fixed
> Implement Netty sender incoming pipeline for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7468:
Summary: Implement sender backlog logic for credit-based (was: Implement
Netty sender backlog logic for
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199702#comment-16199702
]
zhijiang commented on FLINK-7394:
-
[~Zentol], thank you for merging and let me know the rule.
> Manage
[
https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7699.
---
Resolution: Fixed
> Define the BufferListener interface to replace EventListener in BufferProvider
>
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7394.
---
Resolution: Fixed
> Manage exclusive buffers in RemoteInputChannel
>
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7378.
---
Resolution: Fixed
> Create a fix size (non rebalancing) buffer pool type for the floating buffers
>
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7416:
Description:
This is a part of work for credit-based network flow control.
The related works are :
* We
zhijiang created FLINK-7699:
---
Summary: Define the BufferListener interface to replace
EventlListener in BufferProvider
Key: FLINK-7699
URL: https://issues.apache.org/jira/browse/FLINK-7699
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7394:
Summary: Manage exclusive buffers in RemoteInputChannel (was: Implement
basic InputChannel for
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7394:
Description:
This is a part of work for credit-based network flow control.
The basic works are:
*
[
https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7661:
Description:
Currently the {{PartitionRequest}} message contains {{ResultPartitionID}} |
{{queueIndex}} |
[
https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7661:
Description:
Currently the {{PartitionRequest}} message contains
zhijiang created FLINK-7661:
---
Summary: Add credit field in PartitionRequest message
Key: FLINK-7661
URL: https://issues.apache.org/jira/browse/FLINK-7661
Project: Flink
Issue Type: Sub-task
[
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
[
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
zhijiang created FLINK-7468:
---
Summary: Implement Netty sender backlog logic for credit-based
Key: FLINK-7468
URL: https://issues.apache.org/jira/browse/FLINK-7468
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-7456:
---
Assignee: zhijiang
> Implement Netty sender incoming pipeline for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7456:
Description:
This is a part of work for credit-based network flow control.
On sender side, each
zhijiang created FLINK-7456:
---
Summary: Implement Netty sender incoming pipeline for credit-based
Key: FLINK-7456
URL: https://issues.apache.org/jira/browse/FLINK-7456
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7394:
Description:
This is a part of work for credit-based network flow control.
The basic works are:
*
[
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
[
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
1001 - 1100 of 1161 matches
Mail list logo
