[
https://issues.apache.org/jira/browse/FLINK-16690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16690.
Resolution: Fixed
Merged in master: 7dafd1cd65ba8977d923482a810c907ed7d37b59
> Refactor StreamTaskTest to
[
https://issues.apache.org/jira/browse/FLINK-15962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-15962:
-
Fix Version/s: 1.11.0
> Reduce the default chunk size in netty stack
> -
[
https://issues.apache.org/jira/browse/FLINK-15962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-15962.
Resolution: Fixed
Merged in master : 0bc38ba058165aa6751e7e4c654e37203df3aa35
> Reduce the default chunk
[
https://issues.apache.org/jira/browse/FLINK-16653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16653.
Resolution: Fixed
Merged in master: c60d11d40dc288bc467e7414be5fe7bb2f583f17
> Introduce ResultPartitionW
Zhijiang created FLINK-16690:
Summary: Refactor StreamTaskTest to reuse TestTaskBuilder and
MockStreamTaskBuilder
Key: FLINK-16690
URL: https://issues.apache.org/jira/browse/FLINK-16690
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16690:
Assignee: Zhijiang
> Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder
>
[
https://issues.apache.org/jira/browse/FLINK-16653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16653:
-
Fix Version/s: 1.11.0
> Introduce ResultPartitionWriterTestBase for simplifying tests
> ---
[
https://issues.apache.org/jira/browse/FLINK-16653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16653:
-
Issue Type: Task (was: Bug)
> Introduce ResultPartitionWriterTestBase for simplifying tests
>
Zhijiang created FLINK-16653:
Summary: Introduce ResultPartitionWriterTestBase for simplifying
tests
Key: FLINK-16653
URL: https://issues.apache.org/jira/browse/FLINK-16653
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16586.
Release Note:
The argument type of methods inside ShuffleEnvironment#createInputGates and
#createResultPa
[
https://issues.apache.org/jira/browse/FLINK-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16586:
-
Fix Version/s: 1.11.0
> Build ResultSubpartitionInfo and InputChannelInfo in respective constructors
> -
Zhijiang created FLINK-16645:
Summary: Limit the maximum backlogs in subpartitions for data skew
case
Key: FLINK-16645
URL: https://issues.apache.org/jira/browse/FLINK-16645
Project: Flink
Issue
Zhijiang created FLINK-16644:
Summary: HadoopS3FileSystemBehaviorITCase failed with null uri host
Key: FLINK-16644
URL: https://issues.apache.org/jira/browse/FLINK-16644
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-16644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16644:
-
Component/s: (was: FileSystems)
Connectors / FileSystem
> HadoopS3FileSystemBehavio
[
https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16641:
Assignee: Yingjie Cao
> Announce sender's backlog to solve the deadlock issue without exclusive
Zhijiang created FLINK-16641:
Summary: Announce sender's backlog to solve the deadlock issue
without exclusive buffers
Key: FLINK-16641
URL: https://issues.apache.org/jira/browse/FLINK-16641
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16404:
-
Summary: Avoid caching buffers for blocked input channels before barrier
alignment (was: Solve the pote
[
https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16404:
-
Description:
One motivation of this issue is for reducing the in-flight data in the case of
back pressu
[
https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16454.
Resolution: Fixed
Merged in master: 4035f03a1de24b7e292466e9fa0a0de9cb10f358
Merged in release-1.10: 38b8
[
https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12030:
-
Fix Version/s: 1.11.0
> KafkaITCase.testMultipleSourcesOnePartition is unstable
> --
[
https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16454:
-
Environment: (was: The current copyright year is 2014-2019 in NOTICE
files. We should change it to 2
[
https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16454:
-
Description: The current copyright year is 2014-2019 in NOTICE files. We
should change it to 2014-2020.
[
https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060053#comment-17060053
]
Zhijiang commented on FLINK-16227:
--
Some instances
[https://dev.azure.com/rmetzger/5bd
Zhijiang created FLINK-16610:
Summary: FlinkKafkaInternalProducerITCase fails with timeout
exception
Key: FLINK-16610
URL: https://issues.apache.org/jira/browse/FLINK-16610
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059974#comment-17059974
]
Zhijiang commented on FLINK-12030:
--
Another failure instance
[https://dev.azure.com/rm
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-10742:
-
Release Note: After FLINK-10742, while reading data stream from network on
receiver side, it would reuse
[
https://issues.apache.org/jira/browse/FLINK-16554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16554.
Resolution: Fixed
Merged in master: 3b99f7e4d769f6e2b6e9fd8e36a542e063d6c369
> Extract static classes fro
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058701#comment-17058701
]
Zhijiang commented on FLINK-10742:
--
Thanks for the kind reminder [~NicoK]. I think it i
[
https://issues.apache.org/jira/browse/FLINK-16537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16537:
Assignee: Zhijiang
> Implement ResultPartition state recovery for unaligned checkpoint
>
Zhijiang created FLINK-16586:
Summary: Build ResultSubpartitionInfo and InputChannelInfo in
respective constructors
Key: FLINK-16586
URL: https://issues.apache.org/jira/browse/FLINK-16586
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058455#comment-17058455
]
Zhijiang commented on FLINK-16572:
--
Another same failure case in
[https://dev.azure.co
Zhijiang created FLINK-16583:
Summary: SQLClientKafkaITCase.testKafka failed in
SqlClientException
Key: FLINK-16583
URL: https://issues.apache.org/jira/browse/FLINK-16583
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16583:
-
Summary: SQLClientKafkaITCase.testKafka failed with SqlClientException
(was: SQLClientKafkaITCase.testK
[
https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16582:
Assignee: Yun Gao
> NettyBufferPoolTest may have warns on NettyBuffer leak
> ---
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-10742.
Resolution: Fixed
Merged in master: db5d753da7dbac3cc274bba683081503be94c99d
> Let Netty use Flink's buff
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-10742:
-
Fix Version/s: 1.11.0
> Let Netty use Flink's buffers directly in credit-based mode
> --
[
https://issues.apache.org/jira/browse/FLINK-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057716#comment-17057716
]
Zhijiang edited comment on FLINK-10661 at 3/12/20, 8:48 AM:
[
https://issues.apache.org/jira/browse/FLINK-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-10661.
Resolution: Won't Fix
Close now until it is really needed.
> Initial credit should be configured in a sep
[
https://issues.apache.org/jira/browse/FLINK-16564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057675#comment-17057675
]
Zhijiang edited comment on FLINK-16564 at 3/12/20, 7:54 AM:
[
https://issues.apache.org/jira/browse/FLINK-16564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057675#comment-17057675
]
Zhijiang commented on FLINK-16564:
--
Another case [https://api.travis-ci.org/v3/job/6611
Zhijiang created FLINK-16564:
Summary: HadoopS3RecoverableWriterITCase fails with
NullPointerException
Key: FLINK-16564
URL: https://issues.apache.org/jira/browse/FLINK-16564
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057614#comment-17057614
]
Zhijiang commented on FLINK-16227:
--
Another broken for nightly cron :
[https://dev.azu
[
https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16227:
-
Priority: Critical (was: Major)
> Streaming bucketing end-to-end test / test_streaming_bucketing.sh uns
[
https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056698#comment-17056698
]
Zhijiang commented on FLINK-16227:
--
Another instance
[https://dev.azure.com/rmetzger/5
Zhijiang created FLINK-16537:
Summary: Implement ResultPartition state recovery for unaligned
checkpoint
Key: FLINK-16537
URL: https://issues.apache.org/jira/browse/FLINK-16537
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16536:
-
Description:
During recovery process for unaligned checkpoint, the input channel state
should also be r
[
https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16536:
-
Description:
During recovery process for unaligned checkpoint, the input channel state
should also be r
Zhijiang created FLINK-16536:
Summary: Implement InputChannel state recovery for unaligned
checkpoint
Key: FLINK-16536
URL: https://issues.apache.org/jira/browse/FLINK-16536
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056642#comment-17056642
]
Zhijiang edited comment on FLINK-16477 at 3/11/20, 5:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056642#comment-17056642
]
Zhijiang commented on FLINK-16477:
--
Another instance [https://api.travis-ci.org/v3/job/
[
https://issues.apache.org/jira/browse/FLINK-16512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16512.
Resolution: Fixed
Merged in master: 1ad361b787ad2929b334a72e7f5be944f4fe27af
> Add API to persist channel
[
https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055631#comment-17055631
]
Zhijiang commented on FLINK-16477:
--
Another failure instance
[https://dev.azure.com/rm
[
https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053525#comment-17053525
]
Zhijiang commented on FLINK-16454:
--
Thanks for concerning on this. I just created this
[
https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16454:
-
Fix Version/s: 1.11.0
> Update the copyright year in NOTICE files
>
Zhijiang created FLINK-16454:
Summary: Update the copyright year in NOTICE files
Key: FLINK-16454
URL: https://issues.apache.org/jira/browse/FLINK-16454
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-16403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16403:
-
Release Note: (was: Duplicated with FLINK-16404)
> Solve the potential deadlock problem when reducing
[
https://issues.apache.org/jira/browse/FLINK-16403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051367#comment-17051367
]
Zhijiang commented on FLINK-16403:
--
Duplicated with FLINK-16404
> Solve the potential
[
https://issues.apache.org/jira/browse/FLINK-16403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16403.
Release Note: Duplicated with FLINK-16404
Resolution: Duplicate
> Solve the potential deadlock probl
[
https://issues.apache.org/jira/browse/FLINK-16284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16284.
Resolution: Duplicate
Duplicated with FLINK-16285
> Refactor SingleInputGate#setInputChannel to remove
>
[
https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16404:
-
Parent: FLINK-16428
Issue Type: Sub-task (was: Task)
> Solve the potential deadlock problem whe
[
https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16404:
-
Parent: (was: FLINK-7282)
Issue Type: Task (was: Sub-task)
> Solve the potential deadlock p
[
https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16012:
-
Parent: FLINK-16428
Issue Type: Sub-task (was: Improvement)
> Reduce the default number of excl
[
https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16428:
Assignee: Zhijiang
> Fine-grained network buffer management for backpressure
> --
Zhijiang created FLINK-16428:
Summary: Fine-grained network buffer management for backpressure
Key: FLINK-16428
URL: https://issues.apache.org/jira/browse/FLINK-16428
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16404:
Assignee: Yingjie Cao
> Solve the potential deadlock problem when reducing exclusive buffers to z
Zhijiang created FLINK-16404:
Summary: Solve the potential deadlock problem when reducing
exclusive buffers to zero
Key: FLINK-16404
URL: https://issues.apache.org/jira/browse/FLINK-16404
Project: Flink
Zhijiang created FLINK-16403:
Summary: Solve the potential deadlock problem when reducing
exclusive buffers to zero
Key: FLINK-16403
URL: https://issues.apache.org/jira/browse/FLINK-16403
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16285.
Resolution: Fixed
Merged into master: 569468f729e118ab93547d84327ec846cc2646c8
> Refactor SingleInputGate
[
https://issues.apache.org/jira/browse/FLINK-15486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-15486:
Assignee: Yingjie Cao
> LocalInputChannelTest.testConcurrentConsumeMultiplePartitions failing on
[
https://issues.apache.org/jira/browse/FLINK-15486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047418#comment-17047418
]
Zhijiang commented on FLINK-15486:
--
Sorry for touching it so delay [~siddheshghadi] . I
[
https://issues.apache.org/jira/browse/FLINK-16257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16257.
Resolution: Fixed
Merged in master: 556c6d2225dc2c563ddbe5044037f3c2e234fd74
> Remove useless ResultParti
[
https://issues.apache.org/jira/browse/FLINK-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16285:
-
Fix Version/s: 1.11.0
> Refactor SingleInputGate#setInputChannel to remove
> IntermediateResultPartitio
Zhijiang created FLINK-16285:
Summary: Refactor SingleInputGate#setInputChannel to remove
IntermediateResultPartitionID argument
Key: FLINK-16285
URL: https://issues.apache.org/jira/browse/FLINK-16285
Pro
Zhijiang created FLINK-16284:
Summary: Refactor SingleInputGate#setInputChannel to remove
IntermediateResultPartitionID argument
Key: FLINK-16284
URL: https://issues.apache.org/jira/browse/FLINK-16284
Pro
Zhijiang created FLINK-16257:
Summary: Remove useless ResultPartitionID from AddCredit message
Key: FLINK-16257
URL: https://issues.apache.org/jira/browse/FLINK-16257
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-16140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16140:
Assignee: shuai.xu
> Translate "Event Processing (CEP)" page into Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038512#comment-17038512
]
Zhijiang commented on FLINK-16030:
--
Considering the direction of "richer exception hand
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16051:
-
Issue Type: Improvement (was: Bug)
> Subtask id in Checkpoint UI not consistent with Subtask UI
> -
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16051:
Assignee: Jiayi Liao
> Subtask id in Checkpoint UI not consistent with Subtask UI
> -
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16030:
Assignee: begginghard
> Add heartbeat between netty server and client to detect long connection a
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036830#comment-17036830
]
Zhijiang commented on FLINK-16030:
--
After some offline discussions with [~pnowojski], w
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036692#comment-17036692
]
Zhijiang commented on FLINK-16030:
--
I agree with [~pnowojski]'s concern. I forgot the p
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036679#comment-17036679
]
Zhijiang commented on FLINK-15981:
--
> One option to try out would be to not use any mem
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036678#comment-17036678
]
Zhijiang commented on FLINK-15981:
--
Thanks for the confirmation and in general we are o
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16030:
-
Affects Version/s: (was: 1.10.0)
> Add heartbeat between netty server and client to detect long conn
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036085#comment-17036085
]
Zhijiang commented on FLINK-16030:
--
Thanks for opening this issue, [~begginghard] . I t
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16030:
-
Fix Version/s: (was: 1.10.1)
> Add heartbeat between netty server and client to detect long connecti
[
https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-16012:
-
Fix Version/s: 1.11.0
> Reduce the default number of exclusive buffers from 2 to 1 on receiver side
> --
[
https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-16012:
Assignee: Yingjie Cao
> Reduce the default number of exclusive buffers from 2 to 1 on receiver si
zhijiang created FLINK-16012:
Summary: Reduce the default number of exclusive buffers from 2 to
1 on receiver side
Key: FLINK-16012
URL: https://issues.apache.org/jira/browse/FLINK-16012
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035052#comment-17035052
]
zhijiang commented on FLINK-15981:
--
[~sewen] You really proposed some good and critical
[
https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034320#comment-17034320
]
zhijiang commented on FLINK-15914:
--
Merged in master: 2a0555bc85e5256718e6b546ffa768a80
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034110#comment-17034110
]
zhijiang commented on FLINK-15981:
--
Thanks for reporting this issue [~lzljs3620320]
Ac
[
https://issues.apache.org/jira/browse/FLINK-15966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034106#comment-17034106
]
zhijiang commented on FLINK-15966:
--
Very helpful improvement, looking forward for it.
[
https://issues.apache.org/jira/browse/FLINK-15980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-15980:
Assignee: shuai.xu
> The notFollowedBy in the end of GroupPattern may be ignored
> --
[
https://issues.apache.org/jira/browse/FLINK-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-15963:
-
Description:
On sender side while writing the BufferResponse message, it always allocates
the new direc
[
https://issues.apache.org/jira/browse/FLINK-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-15963:
-
Description:
On sender side while writing the BufferResponse message, it always allocates
the new direc
[
https://issues.apache.org/jira/browse/FLINK-15964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-15964:
Assignee: shuai.xu
> Getting previous stage in notFollowedBy may throw exception
> --
[
https://issues.apache.org/jira/browse/FLINK-15962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-15962:
Assignee: Yun Gao
> Reduce the default chunk size in netty stack
> --
zhijiang created FLINK-15963:
Summary: Reuse the same ByteBuf while writing the BufferResponse
header
Key: FLINK-15963
URL: https://issues.apache.org/jira/browse/FLINK-15963
Project: Flink
Issue
401 - 500 of 1163 matches
Mail list logo