[jira] [Closed] (FLINK-16690) Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder

[ 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

[jira] [Updated] (FLINK-15962) 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 updated FLINK-15962: - Fix Version/s: 1.11.0 > Reduce the default chunk size in netty stack >

[jira] [Closed] (FLINK-15962) 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

[jira] [Closed] (FLINK-16653) Introduce ResultPartitionWriterTestBase for simplifying tests

[ 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

[jira] [Created] (FLINK-16690) Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder

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

[jira] [Assigned] (FLINK-16690) Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder

[ 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

[jira] [Updated] (FLINK-16653) 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: - Fix Version/s: 1.11.0 > Introduce ResultPartitionWriterTestBase for simplifying tests >

[jira] [Updated] (FLINK-16653) 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 >

[jira] [Created] (FLINK-16653) 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

[jira] [Updated] (FLINK-16586) Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

[ 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 >

[jira] [Closed] (FLINK-16586) Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

[ 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

[jira] [Created] (FLINK-16645) Limit the maximum backlogs in subpartitions for data skew case

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

[jira] [Created] (FLINK-16644) HadoopS3FileSystemBehaviorITCase failed with null uri host

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

[jira] [Updated] (FLINK-16644) HadoopS3FileSystemBehaviorITCase failed with null uri host

[ 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 >

[jira] [Assigned] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ 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

[jira] [Created] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

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:

[jira] [Updated] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

[ 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

[jira] [Updated] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Closed] (FLINK-16454) Update the copyright year in NOTICE files

[ 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: 

[jira] [Updated] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

[ 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 >

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

[ 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

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

[ 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.

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060053#comment-17060053 ] Zhijiang commented on FLINK-16227: -- Some instances 

[jira] [Created] (FLINK-16610) FlinkKafkaInternalProducerITCase fails with timeout exception

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

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059974#comment-17059974 ] Zhijiang commented on FLINK-12030: -- Another failure instance 

[jira] [Updated] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

[ 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

[jira] [Closed] (FLINK-16554) Extract static classes from StreamTask

[ 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

[jira] [Commented] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058701#comment-17058701 ] Zhijiang commented on FLINK-10742: -- Thanks for the kind reminder [~NicoK]. I think it is worth putting

[jira] [Assigned] (FLINK-16537) Implement ResultPartition state recovery for unaligned checkpoint

[ 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 >

[jira] [Created] (FLINK-16586) Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

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

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058455#comment-17058455 ] Zhijiang commented on FLINK-16572: -- Another same failure case in 

[jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka failed in SqlClientException

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

[jira] [Updated] (FLINK-16583) SQLClientKafkaITCase.testKafka failed with SqlClientException

[ 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:

[jira] [Assigned] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ 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 >

[jira] [Closed] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

[ 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

[jira] [Updated] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

[ 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 >

[jira] [Comment Edited] (FLINK-10661) Initial credit should be configured in a separate parameter

[ https://issues.apache.org/jira/browse/FLINK-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057716#comment-17057716 ] Zhijiang edited comment on FLINK-10661 at 3/12/20, 8:48 AM: Close now unless

[jira] [Closed] (FLINK-10661) Initial credit should be configured in a separate parameter

[ 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

[jira] [Comment Edited] (FLINK-16564) HadoopS3RecoverableWriterITCase fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057675#comment-17057675 ] Zhijiang edited comment on FLINK-16564 at 3/12/20, 7:54 AM: Another case 

[jira] [Commented] (FLINK-16564) HadoopS3RecoverableWriterITCase fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057675#comment-17057675 ] Zhijiang commented on FLINK-16564: -- Another case [https://api.travis-ci.org/v3/job/661185877/log.txt]

[jira] [Created] (FLINK-16564) HadoopS3RecoverableWriterITCase fails with NullPointerException

Zhijiang created FLINK-16564: Summary: HadoopS3RecoverableWriterITCase fails with NullPointerException Key: FLINK-16564 URL: https://issues.apache.org/jira/browse/FLINK-16564 Project: Flink

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057614#comment-17057614 ] Zhijiang commented on FLINK-16227: -- Another broken for nightly cron : 

[jira] [Updated] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ 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

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056698#comment-17056698 ] Zhijiang commented on FLINK-16227: -- Another instance 

[jira] [Created] (FLINK-16537) Implement ResultPartition state recovery for unaligned checkpoint

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

[jira] [Updated] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

[ 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

[jira] [Updated] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

[ 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

[jira] [Created] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

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

[jira] [Comment Edited] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056642#comment-17056642 ] Zhijiang edited comment on FLINK-16477 at 3/11/20, 5:13 AM: Another instance 

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056642#comment-17056642 ] Zhijiang commented on FLINK-16477: -- Another instance 

[jira] [Closed] (FLINK-16512) Add API to persist channel state

[ 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

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055631#comment-17055631 ] Zhijiang commented on FLINK-16477: -- Another failure instance 

[jira] [Commented] (FLINK-16454) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053525#comment-17053525 ] Zhijiang commented on FLINK-16454: -- Thanks for concerning on this. I just created this ticket for

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

[ 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 >

[jira] [Created] (FLINK-16454) 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

[jira] [Updated] (FLINK-16403) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Commented] (FLINK-16403) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ https://issues.apache.org/jira/browse/FLINK-16403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051367#comment-17051367 ] Zhijiang commented on FLINK-16403: -- Duplicated with FLINK-16404 > Solve the potential deadlock problem

[jira] [Closed] (FLINK-16403) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Closed] (FLINK-16284) Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

[ 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

[jira] [Updated] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Updated] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Updated] (FLINK-16012) 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 updated FLINK-16012: - Parent: FLINK-16428 Issue Type: Sub-task (was: Improvement) > Reduce the default number of

[jira] [Assigned] (FLINK-16428) Fine-grained network buffer management for backpressure

[ 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 >

[jira] [Created] (FLINK-16428) 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:

[jira] [Assigned] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero

[ 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

[jira] [Created] (FLINK-16404) Solve the potential deadlock problem when reducing exclusive buffers to zero

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

[jira] [Created] (FLINK-16403) Solve the potential deadlock problem when reducing exclusive buffers to zero

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

[jira] [Closed] (FLINK-16285) Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

[ 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

[jira] [Assigned] (FLINK-15486) LocalInputChannelTest.testConcurrentConsumeMultiplePartitions failing on ppc64le platform.

[ 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

[jira] [Commented] (FLINK-15486) LocalInputChannelTest.testConcurrentConsumeMultiplePartitions failing on ppc64le platform.

[ https://issues.apache.org/jira/browse/FLINK-15486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047418#comment-17047418 ] Zhijiang commented on FLINK-15486: -- Sorry for touching it so delay [~siddheshghadi] . I would assign

[jira] [Closed] (FLINK-16257) Remove useless ResultPartitionID from AddCredit message

[ 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

[jira] [Updated] (FLINK-16285) Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

[ 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 >

[jira] [Created] (FLINK-16285) Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

Zhijiang created FLINK-16285: Summary: Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument Key: FLINK-16285 URL: https://issues.apache.org/jira/browse/FLINK-16285

[jira] [Created] (FLINK-16284) Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

Zhijiang created FLINK-16284: Summary: Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument Key: FLINK-16284 URL: https://issues.apache.org/jira/browse/FLINK-16284

[jira] [Created] (FLINK-16257) Remove useless ResultPartitionID from AddCredit message

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:

[jira] [Assigned] (FLINK-16140) Translate "Event Processing (CEP)" page into Chinese

[ 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 >

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038512#comment-17038512 ] Zhijiang commented on FLINK-16030: -- Considering the direction of "richer exception handling" [~sewen] 

[jira] [Updated] (FLINK-16051) 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 updated FLINK-16051: - Issue Type: Improvement (was: Bug) > Subtask id in Checkpoint UI not consistent with Subtask UI >

[jira] [Assigned] (FLINK-16051) 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 >

[jira] [Assigned] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ 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

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036830#comment-17036830 ] Zhijiang commented on FLINK-16030: -- After some offline discussions with [~pnowojski], we reach the

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036692#comment-17036692 ] Zhijiang commented on FLINK-16030: -- I agree with [~pnowojski]'s concern. I forgot the previous issue

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036679#comment-17036679 ] Zhijiang commented on FLINK-15981: -- > One option to try out would be to not use any memory at all, but

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036678#comment-17036678 ] Zhijiang commented on FLINK-15981: -- Thanks for the confirmation and in general we are on the same page.

[jira] [Updated] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ 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

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036085#comment-17036085 ] Zhijiang commented on FLINK-16030: -- Thanks for opening this issue, [~begginghard] . I think it makes

[jira] [Updated] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

[ 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

[jira] [Updated] (FLINK-16012) 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 updated FLINK-16012: - Fix Version/s: 1.11.0 > Reduce the default number of exclusive buffers from 2 to 1 on receiver side >

[jira] [Assigned] (FLINK-16012) 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

[jira] [Created] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

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

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035052#comment-17035052 ] zhijiang commented on FLINK-15981: -- [~sewen] You really proposed some good and critical questions. I

[jira] [Commented] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034320#comment-17034320 ] zhijiang commented on FLINK-15914: -- Merged in master: 2a0555bc85e5256718e6b546ffa768a80386e892 > Miss

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034110#comment-17034110 ] zhijiang commented on FLINK-15981: -- Thanks for reporting this issue [~lzljs3620320] Actually we also

[jira] [Commented] (FLINK-15966) Capture the call stack of RPC ask() calls.

[ https://issues.apache.org/jira/browse/FLINK-15966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034106#comment-17034106 ] zhijiang commented on FLINK-15966: -- Very helpful improvement, looking forward for it. > Capture the

[jira] [Assigned] (FLINK-15980) The notFollowedBy in the end of GroupPattern may be ignored

[ 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 >

[jira] [Updated] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

[ 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

[jira] [Updated] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

[ 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

[jira] [Assigned] (FLINK-15964) Getting previous stage in notFollowedBy may throw exception

[ 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 >

[jira] [Assigned] (FLINK-15962) 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 reassigned FLINK-15962: Assignee: Yun Gao > Reduce the default chunk size in netty stack >

[jira] [Created] (FLINK-15963) Reuse the same ByteBuf while writing the BufferResponse header

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

<    1   2   3   4   5   6   7   8   9   10   >