[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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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-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] [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] [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] [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] [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] [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] [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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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: FLINK-19551 Issue Type: Sub-task (was: Task) > Introduce API point for ShuffleEnvironme

[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-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-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-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-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] [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-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-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] [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-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] [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-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] [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] [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] [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-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-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: FLINK-19442 Issue Type: Sub-task (was: Task) > Create integration or e2e test for out o

[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] [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-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] [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] [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] [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] [Created] (FLINK-11441) Remove the schedule mode property from RPDD to TDD

zhijiang created FLINK-11441: Summary: Remove the schedule mode property from RPDD to TDD Key: FLINK-11441 URL: https://issues.apache.org/jira/browse/FLINK-11441 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-11460) Remove useless AcknowledgeStreamMockEnvironment

zhijiang created FLINK-11460: Summary: Remove useless AcknowledgeStreamMockEnvironment Key: FLINK-11460 URL: https://issues.apache.org/jira/browse/FLINK-11460 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11461) Remove useless MockRecordWriter

zhijiang created FLINK-11461: Summary: Remove useless MockRecordWriter Key: FLINK-11461 URL: https://issues.apache.org/jira/browse/FLINK-11461 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-11604) Extend the necessary methods in ResultPartitionWriter interface

zhijiang created FLINK-11604: Summary: Extend the necessary methods in ResultPartitionWriter interface Key: FLINK-11604 URL: https://issues.apache.org/jira/browse/FLINK-11604 Project: Flink Issu

[jira] [Closed] (FLINK-11441) Remove the schedule mode property from RPDD to TDD

[ https://issues.apache.org/jira/browse/FLINK-11441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-11441. Resolution: Won't Fix > Remove the schedule mode property from RPDD to TDD > -

[jira] [Created] (FLINK-11646) Remove legacy MockRecordWriter

zhijiang created FLINK-11646: Summary: Remove legacy MockRecordWriter Key: FLINK-11646 URL: https://issues.apache.org/jira/browse/FLINK-11646 Project: Flink Issue Type: Test Components:

[jira] [Assigned] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-6227: --- Assignee: (was: zhijiang) > Introduce the DataConsumptionException for downstream task failure >

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771597#comment-16771597 ] zhijiang commented on FLINK-6227: - [~Salatich], I have not worked on it yet.  And I think

[jira] [Created] (FLINK-11676) Make ResultPartitionWriter extend AutoCloseable

zhijiang created FLINK-11676: Summary: Make ResultPartitionWriter extend AutoCloseable Key: FLINK-11676 URL: https://issues.apache.org/jira/browse/FLINK-11676 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11707) Make InputGate interface extend AutoCloseable

zhijiang created FLINK-11707: Summary: Make InputGate interface extend AutoCloseable Key: FLINK-11707 URL: https://issues.apache.org/jira/browse/FLINK-11707 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11721) Remove IOMode from NetworkEnvironment

zhijiang created FLINK-11721: Summary: Remove IOMode from NetworkEnvironment Key: FLINK-11721 URL: https://issues.apache.org/jira/browse/FLINK-11721 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11723) Remove KvState related components from NetworkEnvironment

zhijiang created FLINK-11723: Summary: Remove KvState related components from NetworkEnvironment Key: FLINK-11723 URL: https://issues.apache.org/jira/browse/FLINK-11723 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774949#comment-16774949 ] zhijiang commented on FLINK-6227: - I think this task seems a bit complicated for the begi

[jira] [Created] (FLINK-11726) Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

zhijiang created FLINK-11726: Summary: Refactor the creation of ResultPartition and InputGate into NetworkEnvironment Key: FLINK-11726 URL: https://issues.apache.org/jira/browse/FLINK-11726 Project: Flink

[jira] [Commented] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777549#comment-16777549 ] zhijiang commented on FLINK-6227: - The initial motivation of this task is to give a hint/

[jira] [Created] (FLINK-11750) Refactor the creation of ResultPartitionID in IntermediateResultPartition

zhijiang created FLINK-11750: Summary: Refactor the creation of ResultPartitionID in IntermediateResultPartition Key: FLINK-11750 URL: https://issues.apache.org/jira/browse/FLINK-11750 Project: Flink

[jira] [Updated] (FLINK-11750) Refactor the creation of ResultPartitionID in IntermediateResultPartition

[ https://issues.apache.org/jira/browse/FLINK-11750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-11750: - Description: The motivation of task is for preparing the creation of {{ResultPartition}} via {{ShuffleS

[jira] [Updated] (FLINK-11750) Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

[ https://issues.apache.org/jira/browse/FLINK-11750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-11750: - Summary: Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescri

[jira] [Commented] (FLINK-11393) Activate default shuffle implementation and remove legacy code

[ https://issues.apache.org/jira/browse/FLINK-11393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778842#comment-16778842 ] zhijiang commented on FLINK-11393: -- [~Salatich], I am glad to see you are interested in

[jira] [Commented] (FLINK-1275) Add support to compress network I/O

[ https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778988#comment-16778988 ] zhijiang commented on FLINK-1275: - [~uce], thanks for creating this valuable ticket befor

[jira] [Created] (FLINK-11776) Refactor to simplify the process of scheduleOrUpdateConsumers

zhijiang created FLINK-11776: Summary: Refactor to simplify the process of scheduleOrUpdateConsumers Key: FLINK-11776 URL: https://issues.apache.org/jira/browse/FLINK-11776 Project: Flink Issue

[jira] [Updated] (FLINK-12882) Remove ExecutionAttemptID field from ShuffleEnvironment#createResultPartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12882: - Description: The {{ExecutionAttemptID}} is only used for constructing {{ResultPartitionID}}  during crea

[jira] [Created] (FLINK-12882) Remove ExecutionAttemptID field from ShuffleEnvironment#createResultPartitionWriters

zhijiang created FLINK-12882: Summary: Remove ExecutionAttemptID field from ShuffleEnvironment#createResultPartitionWriters Key: FLINK-12882 URL: https://issues.apache.org/jira/browse/FLINK-12882 Project:

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16871941#comment-16871941 ] zhijiang commented on FLINK-12909: -- The ticket does not describes the issue well. Any

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16871942#comment-16871942 ] zhijiang commented on FLINK-12909: -- Also you should connect the PR #7191 to this Jira t

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Component/s: (was: API / DataStream) Runtime / Coordination > Job keeps in FAILING

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Affects Version/s: (was: 1.7.2) > Job keeps in FAILING state > -- > >

[jira] [Commented] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang commented on FLINK-12889: -- My previous analysis in ML was as follows:   Actual

[jira] [Comment Edited] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang edited comment on FLINK-12889 at 6/26/19 5:32 AM: --- My

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Priority: Minor (was: Blocker) > Job keeps in FAILING state > -- > >

[jira] [Comment Edited] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang edited comment on FLINK-12889 at 6/26/19 5:33 AM: --- My

[jira] [Updated] (FLINK-12284) InputBufferPoolUsage is incorrect in credit-based network control flow

[ https://issues.apache.org/jira/browse/FLINK-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12284: - Component/s: Runtime / Metrics > InputBufferPoolUsage is incorrect in credit-based network control flow

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

zhijiang created FLINK-13010: Summary: Refactor the process of SchedulerNG#requestPartitionState Key: FLINK-13010 URL: https://issues.apache.org/jira/browse/FLINK-13010 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12882) Remove ExecutionAttemptID field from ShuffleEnvironment#createResultPartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12882: - Description: The ResultPartitionID could be got directly from ResultPartitionDeploymentDescriptor, so it

[jira] [Updated] (FLINK-12882) Remove ExecutionAttemptID argument from ResultPartitionFactory#create

[ https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12882: - Summary: Remove ExecutionAttemptID argument from ResultPartitionFactory#create (was: Remove ExecutionAt

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877073#comment-16877073 ] zhijiang commented on FLINK-12852: -- [~StephanEwen] thanks for concerning this issue and

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877605#comment-16877605 ] zhijiang commented on FLINK-12852: -- The spill way could solve the deadlock issue in fun

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877616#comment-16877616 ] zhijiang commented on FLINK-12852: -- Hey [~gaoyunhaii], considering the second point for

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