Public signup for this instance is disabled. Go to our Self serve sign up page to request an account. Report potential security issues privately

  1. Sub-task FLINK-13435
    Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type
  2. Sub-task FLINK-13141
    Remove getBufferSize method from BufferPoolFactory
  3. Sub-task FLINK-13010
    Refactor the process of SchedulerNG#requestPartitionState
  4. Sub-task FLINK-12960
    Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes
  5. Sub-task FLINK-12890
    Add partition lifecycle related Shuffle API
  6. Sub-task FLINK-12882
    Remove ExecutionAttemptID argument from ResultPartitionFactory#create
  7. Sub-task FLINK-12738
    Remove abstract getPageSize method from InputGate
  8. Sub-task FLINK-12735
    Make shuffle environment implementation independent with IOManager
  9. Sub-task FLINK-12706
    Introduce ShuffleService interface and its configuration
  10. Sub-task FLINK-12673
    Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager
  11. Sub-task FLINK-12630
    Refactor abstract InputGate to general interface
  12. Sub-task FLINK-12603
    Remove getOwningTaskName method from InputGate
  13. Sub-task FLINK-12571
    Make NetworkEnvironment#start() return the binded data port
  14. Sub-task FLINK-12570
    Switch Task from ResultPartition to ResultPartitionWriter interface
  15. Sub-task FLINK-12564
    Remove getBufferProvider method from ResultPartitionWriter interface
  16. Sub-task FLINK-12555
    Introduce an encapsulated metric group layout for shuffle API and deprecate old one
  17. Sub-task FLINK-12530
    Move Task.inputGatesById to NetworkEnvironment
  18. Sub-task FLINK-12497
    Refactor the start method of ConnectionManager
  19. Sub-task FLINK-12331
    Introduce partition/gate setup to decouple task registration with NetworkEnvironment
  20. Sub-task FLINK-12213
    Move network metrics setup into NetworkEnvironment
  21. Sub-task FLINK-12203
    Refactor ResultPartitionManager to break tie with Task
  22. Sub-task FLINK-12202
    Consider introducing batch metric register in NetworkEnviroment
  23. Sub-task FLINK-12201
    Introduce InputGateWithMetrics in Task to increment numBytesIn metric
  24. Sub-task FLINK-12199
    Refactor IOMetrics to not distinguish between local/remote in/out bytes
  25. Sub-task FLINK-12154
    Remove legacy fields for SingleInputGate
  26. Sub-task FLINK-12146
    Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService
  27. Sub-task FLINK-12127
    Move network related options to NetworkEnvironmentOptions
  28. Sub-task FLINK-12078
    Abstract TaskEventPublisher interface for simplifying NetworkEnvironment
  29. Sub-task FLINK-12067
    Refactor the constructor of NetworkEnvironment
  30. Sub-task FLINK-11776
    Refactor to simplify the process of scheduleOrUpdateConsumers
  31. Sub-task FLINK-11750
    Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor
  32. Sub-task FLINK-11726
    Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
  33. Sub-task FLINK-11723
    Remove KvState related components from NetworkEnvironment
  34. Sub-task FLINK-11721
    Remove IOMode from NetworkEnvironment
  35. Sub-task FLINK-11707
    Make InputGate interface extend AutoCloseable
  36. Sub-task FLINK-11676
    Make ResultPartitionWriter extend AutoCloseable
  37. Sub-task FLINK-11604
    Extend the necessary methods in ResultPartitionWriter interface
  38. Sub-task FLINK-11441
    Remove the schedule mode property from RPDD to TDD
  39. Sub-task FLINK-11403
    Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition
  40. Sub-task FLINK-11393
    Activate default shuffle implementation and remove legacy code
  41. Sub-task FLINK-11392
    Introduce ShuffleEnvironment in Task Executor
  42. Sub-task FLINK-11391
    Introduce ShuffleMaster in Job Master
Refresh results