[FLINK-33653][runtime] Introduce a benchmark for balanced tasks scheduling.#109
[FLINK-33653][runtime] Introduce a benchmark for balanced tasks scheduling.#109RocMarshal wants to merge 5 commits into
Conversation
9dadb61 to
db8caf0
Compare
ceabf1c to
8a86e29
Compare
8a86e29 to
0af97e9
Compare
|
Hi, @pnowojski Could you help take a look if you had the free time ? thank you ! |
… jobs with scheduler taskmanager load balance mode.
…ot sharing strategy.
…lot sharing resolver.
…lot request resolver.
…ot request matching.
0af97e9 to
8e064a5
Compare
| import org.apache.flink.runtime.jobmaster.slotpool.SimpleRequestSlotMatchingStrategy; | ||
| import org.apache.flink.runtime.jobmaster.slotpool.TasksBalancedRequestSlotMatchingStrategy; | ||
| import org.apache.flink.runtime.scheduler.adaptive.allocator.TestingSlot; | ||
| import org.apache.flink.runtime.scheduler.loading.DefaultLoadingWeight; |
There was a problem hiding this comment.
It has been renamed in https://github.com/apache/flink/pull/27333/changesgg so it probably should be:
import org.apache.flink.runtime.scheduler.taskexecload.DefaultTaskExecutionLoad;
| private SlotSharingResolverBenchmark benchmark; | ||
|
|
||
| public static void main(String[] args) throws RunnerException { | ||
| runBenchmark(SlotSharingResolverBenchmark.class); |
There was a problem hiding this comment.
This should pass SlotSharingResolverBenchmarkExecutor.class
| private InitSlotSharingStrategyBenchmark benchmark; | ||
|
|
||
| public static void main(String[] args) throws RunnerException { | ||
| runBenchmark(InitSlotSharingStrategyBenchmark.class); |
There was a problem hiding this comment.
This should pass InitSlotSharingStrategyBenchmarkExecutor.class
|
|
||
| @Setup(Level.Trial) | ||
| public void setup() throws Exception { | ||
| slotMatchingResolver = getSlotMatchingResolver(); |
There was a problem hiding this comment.
slotMatchingResolver gets assigned twice here
| } | ||
| } | ||
|
|
||
| public static ResourceProfile newGrainfinedResourceProfile(int slotIndex) { |
There was a problem hiding this comment.
Type: newfineGrainedResourceProfile
|
|
||
| private void configAdaptivePartitioner(StreamExecutionEnvironment env) { | ||
| Configuration config = new Configuration(); | ||
| config.set(TaskManagerOptions.TASK_MANAGER_LOAD_BALANCE_MODE, taskManagerLoadBalanceMode); |
There was a problem hiding this comment.
This will be set after the MiniCluster has already been created, and in my findings it will be ignored. Moving it to InputBenchmarkFlinkEnvironmentContext should solve this
Uh oh!
There was an error while loading. Please reload this page.