This is an automated email from the ASF dual-hosted git repository.
weizhong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 851344d17d5 [FLINK-33653][runtime] Broaden the access scope for
classes associated with the balanced task scheduling benchmark. (#27161)
851344d17d5 is described below
commit 851344d17d557a60701febd2c3c334b4519914cb
Author: Yuepeng Pan <[email protected]>
AuthorDate: Thu Nov 13 17:49:48 2025 +0800
[FLINK-33653][runtime] Broaden the access scope for classes associated with
the balanced task scheduling benchmark. (#27161)
---
.../org/apache/flink/runtime/jobmaster/slotpool/PendingRequest.java | 4 ++--
.../apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java | 2 +-
.../runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java | 4 ++--
.../java/org/apache/flink/runtime/scheduler/SlotSharingStrategy.java | 2 +-
.../runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java | 4 ++--
5 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PendingRequest.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PendingRequest.java
index c25ef0daa61..339db7f575f 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PendingRequest.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PendingRequest.java
@@ -32,7 +32,7 @@ import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
-final class PendingRequest implements WeightLoadable {
+public final class PendingRequest implements WeightLoadable {
private final SlotRequestId slotRequestId;
@@ -72,7 +72,7 @@ final class PendingRequest implements WeightLoadable {
slotRequestId, resourceProfile, loadingWeight,
preferredAllocations, true);
}
- static PendingRequest createNormalRequest(
+ public static PendingRequest createNormalRequest(
SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
LoadingWeight loadingWeight,
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java
index 89122440a56..08a9bfe5dbf 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java
@@ -65,7 +65,7 @@ public class PhysicalSlotRequest implements WeightLoadable {
return slotWillBeOccupiedIndefinitely;
}
- PendingRequest toPendingRequest() {
+ public PendingRequest toPendingRequest() {
return slotWillBeOccupiedIndefinitely
? PendingRequest.createNormalRequest(
slotRequestId,
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java
index 8a57e6b5cdb..c3778a84677 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java
@@ -47,7 +47,7 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
* belong to the same SlotSharingGroup, tend to be put in the same
ExecutionSlotSharingGroup.
* Co-location constraints will be respected.
*/
-class LocalInputPreferredSlotSharingStrategy extends
AbstractSlotSharingStrategy {
+public class LocalInputPreferredSlotSharingStrategy extends
AbstractSlotSharingStrategy {
LocalInputPreferredSlotSharingStrategy(
final SchedulingTopology topology,
@@ -56,7 +56,7 @@ class LocalInputPreferredSlotSharingStrategy extends
AbstractSlotSharingStrategy
super(topology, logicalSlotSharingGroups, coLocationGroups);
}
- static class Factory implements SlotSharingStrategy.Factory {
+ public static class Factory implements SlotSharingStrategy.Factory {
public LocalInputPreferredSlotSharingStrategy create(
final SchedulingTopology topology,
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingStrategy.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingStrategy.java
index 248961a107c..ebb9baf7891 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingStrategy.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingStrategy.java
@@ -26,7 +26,7 @@ import
org.apache.flink.runtime.scheduler.strategy.SchedulingTopology;
import java.util.Set;
/** Strategy which determines {@link ExecutionSlotSharingGroup} for each
execution vertex. */
-interface SlotSharingStrategy {
+public interface SlotSharingStrategy {
ExecutionSlotSharingGroup getExecutionSlotSharingGroup(ExecutionVertexID
executionVertexId);
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java
index 571ac9d3f57..4efef9914a9 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java
@@ -35,7 +35,7 @@ import java.util.Set;
* the same SlotSharingGroup, tend to be put evenly in each
ExecutionSlotSharingGroup. Co-location
* constraints will be respected.
*/
-class TaskBalancedPreferredSlotSharingStrategy extends
AbstractSlotSharingStrategy {
+public class TaskBalancedPreferredSlotSharingStrategy extends
AbstractSlotSharingStrategy {
public static final Logger LOG =
LoggerFactory.getLogger(TaskBalancedPreferredSlotSharingStrategy.class);
@@ -57,7 +57,7 @@ class TaskBalancedPreferredSlotSharingStrategy extends
AbstractSlotSharingStrate
.build();
}
- static class Factory implements SlotSharingStrategy.Factory {
+ public static class Factory implements SlotSharingStrategy.Factory {
public TaskBalancedPreferredSlotSharingStrategy create(
final SchedulingTopology topology,
