[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325754#comment-17325754 ] Zhijiang commented on FLINK-13247: -- [~wind_ljy] Glad to hear that you have implemented

[jira] [Commented] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

[ https://issues.apache.org/jira/browse/FLINK-21858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304031#comment-17304031 ] Zhijiang commented on FLINK-21858: -- I have assigned it to you, but it is better to conf

[jira] [Assigned] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

[ https://issues.apache.org/jira/browse/FLINK-21858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-21858: Assignee: Andrew.D.lin > TaskMetricGroup taskName is too long, especially in sql tasks. > ---

[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268352#comment-17268352 ] Zhijiang commented on FLINK-13247: -- Thanks [~trohrmann] for the operation. Actually I t

[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267020#comment-17267020 ] Zhijiang commented on FLINK-13247: -- AFAIK, the current assignee [~ssy] will not work on

[jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

[ https://issues.apache.org/jira/browse/FLINK-17200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259459#comment-17259459 ] Zhijiang commented on FLINK-17200: -- [~csbliss], I saw your topic in last year's FFA of

[jira] [Commented] (FLINK-20743) Print ContainerId For RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255906#comment-17255906 ] Zhijiang commented on FLINK-20743: -- already assigned. > Print ContainerId For RemoteTr

[jira] [Assigned] (FLINK-20743) Print ContainerId For RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-20743: Assignee: yang gang > Print ContainerId For RemoteTransportException > --

[jira] [Commented] (FLINK-20743) Print ContainerId For RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254795#comment-17254795 ] Zhijiang commented on FLINK-20743: -- Thanks for creating this issue [~清月]. I remembered

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231688#comment-17231688 ] Zhijiang commented on FLINK-16753: -- Thanks for the reminder [~NicoK]. I ever considere

[jira] [Commented] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

[ https://issues.apache.org/jira/browse/FLINK-19907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224507#comment-17224507 ] Zhijiang commented on FLINK-19907: -- I am not quite sure the actual semantic for the new

[jira] [Closed] (FLINK-19745) Supplement micro-benchmark for bounded blocking partition in remote channel case

[ https://issues.apache.org/jira/browse/FLINK-19745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19745. Resolution: Fixed Merged in master: 333eb8ebf116756911dc7e1da59489b5cd9ea475 > Supplement micro-benchmark

[jira] [Created] (FLINK-19745) Supplement micro-benchmark for bounded blocking partition in remote channel case

Zhijiang created FLINK-19745: Summary: Supplement micro-benchmark for bounded blocking partition in remote channel case Key: FLINK-19745 URL: https://issues.apache.org/jira/browse/FLINK-19745 Project: Fli

[jira] [Closed] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16051. Resolution: Duplicate > Subtask ID in Overview-Subtasks should start from 1 >

[jira] [Closed] (FLINK-7315) use flink's buffers in netty

[ https://issues.apache.org/jira/browse/FLINK-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-7315. --- Resolution: Fixed > use flink's buffers in netty > > > Key: FLIN

[jira] [Closed] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-12909. Resolution: Later I will close this issue for cleanup since the contributor was not active for long time

[jira] [Commented] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217345#comment-17217345 ] Zhijiang commented on FLINK-16051: -- [~wind_ljy], do you think we can close this issue f

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217343#comment-17217343 ] Zhijiang edited comment on FLINK-19249 at 10/20/20, 6:50 AM: -

[jira] [Commented] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217343#comment-17217343 ] Zhijiang commented on FLINK-19249: -- I dig out the previously discussed issues [FLINK-1

[jira] [Commented] (FLINK-13802) Flink code style guide

[ https://issues.apache.org/jira/browse/FLINK-13802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217340#comment-17217340 ] Zhijiang commented on FLINK-13802: -- [~azagrebin]. Just remind do you think this umbrell

[jira] [Closed] (FLINK-14525) buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-14525. Resolution: Won't Fix > buffer pool is destroyed > > > Key: FLINK

[jira] [Commented] (FLINK-14525) buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217338#comment-17217338 ] Zhijiang commented on FLINK-14525: -- Close this issue for cleanup, since the reporter wa

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

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15981: - Fix Version/s: 1.12.0 > Control the direct memory in FileChannelBoundedData.FileBufferReader > -

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

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-15981: Assignee: Zhijiang > Control the direct memory in FileChannelBoundedData.FileBufferReader > -

[jira] [Commented] (FLINK-18427) Job failed under java 11

[ https://issues.apache.org/jira/browse/FLINK-18427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217331#comment-17217331 ] Zhijiang commented on FLINK-18427: -- [~xintongsong] might be more familiar with the conc

[jira] [Comment Edited] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

[ https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216520#comment-17216520 ] Zhijiang edited comment on FLINK-19596 at 10/19/20, 8:04 AM: -

[jira] [Commented] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

[ https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216520#comment-17216520 ] Zhijiang commented on FLINK-19596: -- I heard of this issue proposed long time ago from [

[jira] [Commented] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

[ https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216517#comment-17216517 ] Zhijiang commented on FLINK-19596: -- Thanks for proposing this potential improvement [~w

[jira] [Closed] (FLINK-19155) ResultPartitionTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-19155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19155. Resolution: Won't Fix Close it since this ut has already been removed in another refactoring work. > Resu

[jira] [Closed] (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 closed FLINK-15963. Resolution: Later Close it for cleanup since it is not really critical by now and nobody has time to work

[jira] [Closed] (FLINK-16739) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key

[ https://issues.apache.org/jira/browse/FLINK-16739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16739. Resolution: Cannot Reproduce Close it for cleanup since it was not reproduced in recent half a year. > Pr

[jira] [Updated] (FLINK-17741) Create integration or e2e test for out of order (savepoint) barriers

[ https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17741: - Parent: FLINK-19442 Issue Type: Sub-task (was: Task) > Create integration or e2e test for out o

[jira] [Closed] (FLINK-15187) Reuse LocalBufferPool for FileBufferReader in blocking partition

[ https://issues.apache.org/jira/browse/FLINK-15187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-15187. Resolution: Fixed Resolved in FLINK-15981 > Reuse LocalBufferPool for FileBufferReader in blocking partit

[jira] [Updated] (FLINK-17741) Create integration or e2e test for out of order (savepoint) barriers

[ https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17741: - Parent: (was: FLINK-14551) Issue Type: Task (was: Sub-task) > Create integration or e2e tes

[jira] [Closed] (FLINK-14551) Unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-14551. Resolution: Fixed > Unaligned checkpoints > - > > Key: FLINK-14551 >

[jira] [Updated] (FLINK-14551) Unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-14551: - Fix Version/s: (was: 1.12.0) 1.11.0 > Unaligned checkpoints > ---

[jira] [Commented] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212929#comment-17212929 ] Zhijiang commented on FLINK-9253: - [~NicoK] I just closed the parent umbrella ticket for

[jira] [Closed] (FLINK-7282) Credit-based Network Flow Control

[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-7282. --- Resolution: Fixed > Credit-based Network Flow Control > - > >

[jira] [Closed] (FLINK-13478) Decouple two different release strategies in BoundedBlockingSubpartition

[ https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-13478. Resolution: Won't Fix This issue is out of date since partition release logics have changed a lot before.

[jira] [Closed] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

[ https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-13493. Resolution: Later Close this issue for cleanup since it is not really important ATM and we can reopen it

[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: (was: Zhijiang) > Fine-grained network buffer management for backpressure > ---

[jira] [Closed] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16753. Resolution: Fixed Merged in master: a1b1dc95210e99e6c23069415283fce4ec3793a5 > Exception from AsyncCheckp

[jira] [Updated] (FLINK-10653) Introduce Pluggable Shuffle Service Architecture

[ https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-10653: - Fix Version/s: 1.9.0 > Introduce Pluggable Shuffle Service Architecture > --

[jira] [Closed] (FLINK-10653) Introduce Pluggable Shuffle Service Architecture

[ https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-10653. Resolution: Fixed [~trohrmann], thanks for this kind reminder,:). I already migrated all the pending open

[jira] [Updated] (FLINK-12873) Create a separate maven module for Shuffle API

[ https://issues.apache.org/jira/browse/FLINK-12873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12873: - Parent: (was: FLINK-10653) Issue Type: Task (was: Sub-task) > Create a separate maven modul

[jira] [Updated] (FLINK-12873) Create a separate maven module for Shuffle API

[ https://issues.apache.org/jira/browse/FLINK-12873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12873: - Parent: FLINK-19551 Issue Type: Sub-task (was: Task) > Create a separate maven module for Shuff

[jira] [Updated] (FLINK-12731) Load shuffle service implementations from plugin manager

[ https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12731: - Parent: (was: FLINK-10653) Issue Type: Task (was: Sub-task) > Load shuffle service implemen

[jira] [Updated] (FLINK-12731) Load shuffle service implementations from plugin manager

[ https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12731: - Parent: FLINK-19551 Issue Type: Sub-task (was: Task) > Load shuffle service implementations fro

[jira] [Updated] (FLINK-12543) Consider naming convention for config options of shuffle services

[ https://issues.apache.org/jira/browse/FLINK-12543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12543: - Parent: FLINK-19551 Issue Type: Sub-task (was: Task) > Consider naming convention for config op

[jira] [Updated] (FLINK-12543) Consider naming convention for config options of shuffle services

[ https://issues.apache.org/jira/browse/FLINK-12543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12543: - Parent: (was: FLINK-10653) Issue Type: Task (was: Sub-task) > Consider naming convention fo

[jira] [Updated] (FLINK-13642) Refactor ShuffleMaster to optionally provide preferred TM location for produced partitions

[ https://issues.apache.org/jira/browse/FLINK-13642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-13642: - Parent: FLINK-19551 Issue Type: Sub-task (was: Task) > Refactor ShuffleMaster to optionally pro

[jira] [Updated] (FLINK-12110) Introduce API point for ShuffleEnvironment to get estimation of locally required memory

[ https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12110: - Parent: (was: FLINK-10653) Issue Type: Task (was: Sub-task) > Introduce API point for Shuff

[jira] [Updated] (FLINK-12110) Introduce API point for ShuffleEnvironment to get estimation of locally required memory

[ https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12110: - Parent: FLINK-19551 Issue Type: Sub-task (was: Task) > Introduce API point for ShuffleEnvironme

[jira] [Updated] (FLINK-13642) Refactor ShuffleMaster to optionally provide preferred TM location for produced partitions

[ https://issues.apache.org/jira/browse/FLINK-13642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-13642: - Parent: (was: FLINK-10653) Issue Type: Task (was: Sub-task) > Refactor ShuffleMaster to opt

[jira] [Created] (FLINK-19551) Follow up improvements for shuffle service

Zhijiang created FLINK-19551: Summary: Follow up improvements for shuffle service Key: FLINK-19551 URL: https://issues.apache.org/jira/browse/FLINK-19551 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-12110) Introduce API point for ShuffleEnvironment to get estimation of locally required memory

[ https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-12110: Assignee: (was: Zhijiang) > Introduce API point for ShuffleEnvironment to get estimation of l

[jira] [Closed] (FLINK-13010) Refactor the process of SchedulerNG#requestPartitionState

[ https://issues.apache.org/jira/browse/FLINK-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-13010. Resolution: Later Close it for cleanup, then consider reopening it future once necessary and available fo

[jira] [Commented] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204453#comment-17204453 ] Zhijiang commented on FLINK-19249: -- Thanks for reporting this [~klion26] and all the ab

[jira] [Commented] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204445#comment-17204445 ] Zhijiang commented on FLINK-17331: -- After offline discussing with [~karmagyz], i am awa

[jira] [Assigned] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17331: Assignee: Yangze Guo > Add NettyMessageContent interface for all the class which could be write t

[jira] [Updated] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17331: - Fix Version/s: (was: 1.12.0) > Add NettyMessageContent interface for all the class which could be wr

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202759#comment-17202759 ] Zhijiang commented on FLINK-19400: -- +1 to remove, it is indeed no actual usages in core

[jira] [Assigned] (FLINK-19297) Make ResultPartitionWriter record-oriented

[ https://issues.apache.org/jira/browse/FLINK-19297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-19297: Assignee: Yingjie Cao > Make ResultPartitionWriter record-oriented >

[jira] [Assigned] (FLINK-19299) NettyShuffleEnvironmentBuilder#setBufferSize does not take effect

[ https://issues.apache.org/jira/browse/FLINK-19299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-19299: Assignee: Yingjie Cao > NettyShuffleEnvironmentBuilder#setBufferSize does not take effect > -

[jira] [Comment Edited] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191748#comment-17191748 ] Zhijiang edited comment on FLINK-18832 at 9/8/20, 8:10 AM: --- Me

[jira] [Assigned] (FLINK-19155) ResultPartitionTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-19155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-19155: Assignee: Zhijiang > ResultPartitionTest is unstable > --- > >

[jira] [Closed] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18832. Resolution: Fixed Merged in master: 13e0b355d1d9ba513671de1638d3c35edb6b96a3 > BoundedBlockingSubpartitio

[jira] [Updated] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-19109: - Fix Version/s: (was: 1.10.3) > Split Reader eats chained periodic watermarks > -

[jira] [Closed] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19109. Resolution: Fixed Merged in master: 361ccb3ad734490aa4df9aa9d0430a31680581db Merged in release-1.11: bae7d

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191577#comment-17191577 ] Zhijiang commented on FLINK-19109: -- [~zhuzh][~roman_khachatryan], I will merge it in 1.

[jira] [Closed] (FLINK-19093) "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1"

[ https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19093. Resolution: Fixed Merged in master: 76f37551ad51f7eae9688495130a39b0f202c3bf > "Elasticsearch (v6.3.1) si

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

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15981: - Affects Version/s: 1.10.1 1.11.0 1.10.2

[jira] [Commented] (FLINK-19054) KafkaTableITCase.testKafkaSourceSink hangs

[ https://issues.apache.org/jira/browse/FLINK-19054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188111#comment-17188111 ] Zhijiang commented on FLINK-19054: -- Anther instance https://dev.azure.com/apache-flink

[jira] [Closed] (FLINK-18694) Add unaligned checkpoint config to web ui

[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18694. Resolution: Fixed Merged in master: 56ee6b49c594ac5da12a8d5d666d61bccf9e4083 > Add unaligned checkpoint c

[jira] [Updated] (FLINK-18694) Add unaligned checkpoint config to web ui

[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18694: - Fix Version/s: 1.12.0 > Add unaligned checkpoint config to web ui >

[jira] [Assigned] (FLINK-18694) Add unaligned checkpoint config to web ui

[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18694: Assignee: Kboh > Add unaligned checkpoint config to web ui >

[jira] [Closed] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

[ https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19012. Resolution: Fixed Merged in master : 378115ffd1642c782c7d0f203c5c46e07d18fc23 > E2E test fails with "Cann

[jira] [Closed] (FLINK-19003) Add micro-benchmark for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-19003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19003. Resolution: Fixed Merged in master: de049572690f4f744c9706dba5268e242f9e3bc8 > Add micro-benchmark for un

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184963#comment-17184963 ] Zhijiang commented on FLINK-18695: -- If I understood correctly, there seems three option

[jira] [Assigned] (FLINK-18955) Add snapshot path to job startup message

[ https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18955: Assignee: Yuan Mei > Add snapshot path to job startup message > -

[jira] [Created] (FLINK-19003) Add micro-benchmark for unaligned checkpoints

Zhijiang created FLINK-19003: Summary: Add micro-benchmark for unaligned checkpoints Key: FLINK-19003 URL: https://issues.apache.org/jira/browse/FLINK-19003 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176817#comment-17176817 ] Zhijiang commented on FLINK-18832: -- [~pnowojski] Agree with you proposal. It would be n

[jira] [Comment Edited] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

[ https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176163#comment-17176163 ] Zhijiang edited comment on FLINK-18821 at 8/13/20, 3:46 AM:

[jira] [Closed] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

[ https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18821. Resolution: Fixed Merged in release-1.11: ded539e85444f9c8d34f88da31784775ed281aba Merged in master: 33bdc

[jira] [Commented] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175960#comment-17175960 ] Zhijiang commented on FLINK-18832: -- Thanks for the explanation [~dwysakowicz]. If so,

[jira] [Closed] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18796. Resolution: Fixed > FlinkKinesisProducer.backpressureLatch should be volatile > --

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172778#comment-17172778 ] Zhijiang commented on FLINK-18796: -- Merged in master: 33bdc978a059c50ec55b8f24d40039d13

[jira] [Assigned] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18832: Assignee: Zhijiang > BoundedBlockingSubpartition does not work with StreamTask >

[jira] [Comment Edited] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171894#comment-17171894 ] Zhijiang edited comment on FLINK-18832 at 8/6/20, 4:15 AM: --- Th

[jira] [Commented] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171894#comment-17171894 ] Zhijiang commented on FLINK-18832: -- Thanks for reporting this bug [~trohrmann]! By des

[jira] [Assigned] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

[ https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18821: Assignee: Roman Khachatryan (was: Roman Kishchenko) > Netty client retry mechanism may cause >

[jira] [Assigned] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

[ https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18821: Assignee: Roman Kishchenko > Netty client retry mechanism may cause > PartitionRequestClientFact

[jira] [Closed] (FLINK-18767) Streaming job stuck when disabling operator chaining

[ https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18767. Resolution: Not A Problem > Streaming job stuck when disabling operator chaining > ---

[jira] [Commented] (FLINK-18767) Streaming job stuck when disabling operator chaining

[ https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169904#comment-17169904 ] Zhijiang commented on FLINK-18767: -- After confirming with [~NicoK] offline, it had some

[jira] [Updated] (FLINK-18767) Streaming job stuck when disabling operator chaining

[ https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18767: - Affects Version/s: (was: 1.8.3) > Streaming job stuck when disabling operator chaining > ---

[jira] [Assigned] (FLINK-18767) Streaming job stuck when disabling operator chaining

[ https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18767: Assignee: Zhijiang > Streaming job stuck when disabling operator chaining > -

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168391#comment-17168391 ] Zhijiang edited comment on FLINK-18695 at 7/31/20, 4:40 AM:

[jira] [Assigned] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18695: Assignee: Yun Gao > Allow NettyBufferPool to allocate heap buffers >

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168391#comment-17168391 ] Zhijiang commented on FLINK-18695: -- {quot} How problematic would it be to backport this

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang edited comment on FLINK-18695 at 7/30/20, 5:59 AM:

  1   2   3   4   5   6   7   8   9   10   >