[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407767#comment-17407767 ] Jin Xing commented on FLINK-22672: -- Yes, Joe ~ I believe the open source work of Latti

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391525#comment-17391525 ] Jin Xing commented on FLINK-22672: -- Resolve this umbrella for Release-1.14. Unfinished

[jira] [Closed] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing closed FLINK-22672. Resolution: Fixed > Some enhancements for pluggable shuffle service framework > --

[jira] [Updated] (FLINK-22768) ShuffleMaster supports to promote partitions

[ https://issues.apache.org/jira/browse/FLINK-22768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22768: - Parent: FLINK-23586 Issue Type: Sub-task (was: Improvement) > ShuffleMaster supports to promote

[jira] [Updated] (FLINK-22768) ShuffleMaster supports to promote partitions

[ https://issues.apache.org/jira/browse/FLINK-22768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22768: - Parent: (was: FLINK-22672) Issue Type: Improvement (was: Sub-task) > ShuffleMaster supports

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Parent: FLINK-23586 Issue Type: Sub-task (was: Improvement) > Pluggable shuffle service public

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Parent: (was: FLINK-22672) Issue Type: Improvement (was: Sub-task) > Pluggable shuffle serv

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Priority: Major (was: Minor) > Pluggable shuffle service public interface IndexedInputGate mixed with N

[jira] [Updated] (FLINK-23586) Further enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-23586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23586: - Description: This Jira targets to track unfinished subtasks from FLINK-22676 and postpone to following F

[jira] [Created] (FLINK-23586) Further enhancements for pluggable shuffle service framework

Jin Xing created FLINK-23586: Summary: Further enhancements for pluggable shuffle service framework Key: FLINK-23586 URL: https://issues.apache.org/jira/browse/FLINK-23586 Project: Flink Issue T

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380262#comment-17380262 ] Jin Xing commented on FLINK-22672: -- Thanks Till ! I think that will be good ~ > Some

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379635#comment-17379635 ] Jin Xing commented on FLINK-22672: -- >  This is great to hear. I am looking forward to t

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377958#comment-17377958 ] Jin Xing commented on FLINK-22672: -- Thanks [~trohrmann] ~ Yes, we are planning to open

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22672: - Description: "Pluggable shuffle service" in Flink provides an architecture which are unified for both s

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22672: - Description: "Pluggable shuffle service" in Flink provides an architecture which are unified for both s

[jira] [Commented] (FLINK-15031) Automatically calculate required network memory for fine-grained jobs

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372534#comment-17372534 ] Jin Xing commented on FLINK-15031: -- Thanks a lot [~zhuzh] ~ I think your comments make

[jira] [Commented] (FLINK-15031) Automatically calculate required network memory for fine-grained jobs

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371012#comment-17371012 ] Jin Xing commented on FLINK-15031: -- Some details for network memory allocation algorith

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Priority: Major (was: Blocker) > PartitionRequestClientFactory#createPartitionRequestClient should thro

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Created] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

Jin Xing created FLINK-23030: Summary: PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure Key: FLINK-23030 URL: https://issues.apache.org/jira/browse/FLINK-23030

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Commented] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355540#comment-17355540 ] Jin Xing commented on FLINK-22676: -- Thanks Till for help on this ~ {quote}This is a val

[jira] [Commented] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355162#comment-17355162 ] Jin Xing commented on FLINK-22676: -- In current Flink, JMPartitonTracker works independe

[jira] [Commented] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355141#comment-17355141 ] Jin Xing commented on FLINK-22676: -- Hi, Till ~ Yes, I think we are on the same page --

[jira] [Comment Edited] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352346#comment-17352346 ] Jin Xing edited comment on FLINK-15031 at 5/27/21, 9:27 AM:

[jira] [Comment Edited] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352346#comment-17352346 ] Jin Xing edited comment on FLINK-15031 at 5/27/21, 9:23 AM:

[jira] [Comment Edited] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352346#comment-17352346 ] Jin Xing edited comment on FLINK-15031 at 5/27/21, 9:23 AM:

[jira] [Comment Edited] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352346#comment-17352346 ] Jin Xing edited comment on FLINK-15031 at 5/27/21, 9:20 AM:

[jira] [Commented] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352346#comment-17352346 ] Jin Xing commented on FLINK-15031: -- Calculating and announcing the volume of required n

[jira] [Comment Edited] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17253414#comment-17253414 ] Jin Xing edited comment on FLINK-20716 at 5/26/21, 9:54 AM:

[jira] [Commented] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351679#comment-17351679 ] Jin Xing commented on FLINK-20716: -- InputChannel is a part of "pluggable shuffle servic

[jira] [Updated] (FLINK-22768) ShuffleMaster supports to promote partitions

[ https://issues.apache.org/jira/browse/FLINK-22768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22768: - Description: Current Flink only supports to promote data partitions in TM internal shuffle service. Plug

[jira] [Created] (FLINK-22768) ShuffleMaster supports to promote partitions

Jin Xing created FLINK-22768: Summary: ShuffleMaster supports to promote partitions Key: FLINK-22768 URL: https://issues.apache.org/jira/browse/FLINK-22768 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350933#comment-17350933 ] Jin Xing commented on FLINK-22676: -- Gentle ping [~pnowojski] [~chesnay] Would you plea

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22676: - Description: In current Flink, data partition is bound with the ResourceID of TM in Execution#startTrac

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22672: - Description: "Pluggable shuffle service" in Flink provides an architecture which are unified for both s

[jira] [Updated] (FLINK-22675) Add an interface method ShuffleMaster#close

[ https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22675: - Description: When extending remote shuffle service based on 'pluggable shuffle service',  ShuffleMaster

[jira] [Updated] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

[ https://issues.apache.org/jira/browse/FLINK-22677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22677: - Description: Current scheduler enforces a synchronous registration though the API of ShuffleMaster#regis

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Description: In current "pluggable shuffle service", IndexedInputGate defines the reading for a single i

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Parent: FLINK-22672 Issue Type: Sub-task (was: Bug) > Pluggable shuffle service public interfac

[jira] [Created] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

Jin Xing created FLINK-22677: Summary: Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion Key: FLINK-22677 URL: https://issues.apache.org/jira/browse/FLINK-22677

[jira] [Created] (FLINK-22676) The partition tracker should support remote shuffle properly

Jin Xing created FLINK-22676: Summary: The partition tracker should support remote shuffle properly Key: FLINK-22676 URL: https://issues.apache.org/jira/browse/FLINK-22676 Project: Flink Issue T

[jira] [Created] (FLINK-22675) Add an interface method ShuffleMaster#close

Jin Xing created FLINK-22675: Summary: Add an interface method ShuffleMaster#close Key: FLINK-22675 URL: https://issues.apache.org/jira/browse/FLINK-22675 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

Jin Xing created FLINK-22674: Summary: Provide JobID when apply shuffle resource by ShuffleMaster Key: FLINK-22674 URL: https://issues.apache.org/jira/browse/FLINK-22674 Project: Flink Issue Type

[jira] [Created] (FLINK-22672) Some enhancements for pluggable shuffle service framework

Jin Xing created FLINK-22672: Summary: Some enhancements for pluggable shuffle service framework Key: FLINK-22672 URL: https://issues.apache.org/jira/browse/FLINK-22672 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329951#comment-17329951 ] Jin Xing commented on FLINK-22276: -- Thanks [~mapohl] ~ I tried the patch and it works v

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324734#comment-17324734 ] Jin Xing commented on FLINK-22276: -- Thanks a lot for quick fix ~ I will try the PR and

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322112#comment-17322112 ] Jin Xing commented on FLINK-22276: -- Thanks a lot [~mapohl] > ExceptionHistoryEntryExtr

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits: !i

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: image-2021-04-15-14-46-42-660.png > ExceptionHistoryEntryExtractor throws fatal error when t

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits: !i

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits: !i

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: log > ExceptionHistoryEntryExtractor throws fatal error when task failure >

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits: !i

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: image-2021-04-14-17-50-45-199.png > ExceptionHistoryEntryExtractor throws fatal error when t

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits:   

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: (was: image-2021-04-14-17-47-42-323.png) > ExceptionHistoryEntryExtractor throws fatal e

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits:  

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: (was: image-2021-04-14-17-49-32-798.png) > ExceptionHistoryEntryExtractor throws fatal e

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Description: When running my batch job on Flink cluster, I got a fatal error as below and JM exits:  

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22276: - Attachment: image-2021-04-14-17-49-32-798.png > ExceptionHistoryEntryExtractor throws fatal error when t

[jira] [Created] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

Jin Xing created FLINK-22276: Summary: ExceptionHistoryEntryExtractor throws fatal error when task failure Key: FLINK-22276 URL: https://issues.apache.org/jira/browse/FLINK-22276 Project: Flink

[jira] [Commented] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17253414#comment-17253414 ] Jin Xing commented on FLINK-20716: -- Gentle ping [~AHeise] [~kevin.cyj]; Also I think t

[jira] [Updated] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

[ https://issues.apache.org/jira/browse/FLINK-20716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-20716: - Description: IndexedInputGate provided by pluggable shuffle service as a public interface, and intend to

[jira] [Created] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation.

Jin Xing created FLINK-20716: Summary: Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation. Key: FLINK-20716 URL: https://issues.apache.org/jira/browse/FLINK-207

[jira] [Comment Edited] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink

[ https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240704#comment-17240704 ] Jin Xing edited comment on FLINK-19343 at 11/30/20, 11:54 AM:

[jira] [Commented] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink

[ https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240704#comment-17240704 ] Jin Xing commented on FLINK-19343: -- My team is considering the design of "Remote Shuffl

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/17/20, 1:38 AM: -

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/16/20, 3:56 AM: -

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/16/20, 3:54 AM: -

[jira] [Commented] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing commented on FLINK-20038: -- Hi [~trohrmann] [~ym] Thanks a lot for your feedba

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227720#comment-17227720 ] Jin Xing edited comment on FLINK-20038 at 11/7/20, 4:10 AM:

[jira] [Commented] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227720#comment-17227720 ] Jin Xing commented on FLINK-20038: -- Gentle ping [~zhuzh] and [~azagrebin] Flink master

[jira] [Created] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

Jin Xing created FLINK-20038: Summary: Rectify the usage of ResultPartitionType#isPipelined() in partition tracker. Key: FLINK-20038 URL: https://issues.apache.org/jira/browse/FLINK-20038 Project: Flink

[jira] [Commented] (FLINK-19693) Scheduler Change for Approximate Local Recovery to Restart Downstream of a Failed Task

[ https://issues.apache.org/jira/browse/FLINK-19693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225467#comment-17225467 ] Jin Xing commented on FLINK-19693: -- Hi, Yuan  ~ I posted above comment after learning t

[jira] [Commented] (FLINK-19693) Scheduler Change for Approximate Local Recovery to Restart Downstream of a Failed Task

[ https://issues.apache.org/jira/browse/FLINK-19693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225464#comment-17225464 ] Jin Xing commented on FLINK-19693: -- Hi, Yuan ~ I just learnt this series of JIRA & PRs,

[jira] [Commented] (FLINK-11144) Make Tests runnable on Java 9

[ https://issues.apache.org/jira/browse/FLINK-11144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908117#comment-16908117 ] jin xing commented on FLINK-11144: -- With this change, I failed the building. Apache Mav