[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

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

[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

[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

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

[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