Skip to content

Commit

Permalink
[FLINK-20595][runtime] Deleted SlotProviderStrategy and corresponding…
Browse files Browse the repository at this point in the history
… TestingSlotProviderStrategy.

This closes apache#14521.
  • Loading branch information
XComp authored and tillrohrmann committed Dec 30, 2020
1 parent 88dd3c4 commit 2b5e6f5
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 163 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -186,9 +186,6 @@ public class ExecutionGraph implements AccessExecutionGraph {
/** The timeout for slot allocations. */
private final Time allocationTimeout;

/** The slot provider strategy to use for allocating slots for tasks as they are needed. */
private final SlotProviderStrategy slotProviderStrategy;

/** The classloader for the user code. Needed for calls into user code classes. */
private final ClassLoader userClassLoader;

Expand Down Expand Up @@ -323,8 +320,6 @@ public ExecutionGraph(
this.futureExecutor = Preconditions.checkNotNull(futureExecutor);
this.ioExecutor = Preconditions.checkNotNull(ioExecutor);

this.slotProviderStrategy =
SlotProviderStrategy.from(scheduleMode, slotProvider, allocationTimeout);
this.userClassLoader = Preconditions.checkNotNull(userClassLoader, "userClassLoader");

this.tasks = new HashMap<>(16);
Expand Down Expand Up @@ -574,10 +569,6 @@ public String getJsonPlan() {
return jsonPlan;
}

public SlotProviderStrategy getSlotProviderStrategy() {
return slotProviderStrategy;
}

public Either<SerializedValue<JobInformation>, PermanentBlobKey> getJobInformationOrBlobKey() {
return jobInformationOrBlobKey;
}
Expand Down

This file was deleted.

This file was deleted.

0 comments on commit 2b5e6f5

Please sign in to comment.