Interface JobShuffleContext

  • All Known Implementing Classes:
    JobShuffleContextImpl

    public interface JobShuffleContext
    Job level shuffle context which can offer some job information like job ID and through it, the shuffle plugin notify the job to stop tracking the lost result partitions.
    • Method Detail

      • getJobId

        org.apache.flink.api.common.JobID getJobId()
        Returns:
        the corresponding JobID.
      • stopTrackingAndReleasePartitions

        CompletableFuture<?> stopTrackingAndReleasePartitions​(Collection<ResultPartitionID> partitionIds)
        Notifies the job to stop tracking and release the target result partitions, which means these partitions will be removed and will be reproduced if used afterwards.