class TaskExecutorPartitionTrackerImpl extends AbstractPartitionTracker<JobID, TaskExecutorPartitionInfo> implements TaskExecutorPartitionTracker {

	@Override
	public void stopTrackingAndReleaseJobPartitionsFor(JobID producingJobId) {
		Collection<ResultPartitionID> partitionsForJob = CollectionUtil.project(
			stopTrackingPartitionsFor(producingJobId),
			PartitionTrackerEntry::getResultPartitionId);
		shuffleEnvironment.releasePartitionsLocally(partitionsForJob);
	}

	public  TaskExecutorPartitionTrackerImpl(ShuffleEnvironment<?, ?> shuffleEnvironment);

}