File tree Expand file tree Collapse file tree 6 files changed +8
-9
lines changed
docs/layouts/shortcodes/generated
flink-core/src/main/java/org/apache/flink/configuration
main/java/org/apache/flink/runtime/scheduler/adaptive
test/java/org/apache/flink/runtime/scheduler/adaptive Expand file tree Collapse file tree 6 files changed +8
-9
lines changed Original file line number Diff line number Diff line change 9
9
</ thead >
10
10
< tbody >
11
11
< tr >
12
- < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-rescale -trigger</ h5 > </ td >
12
+ < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-scale -trigger</ h5 > </ td >
13
13
< td style ="word-wrap: break-word; "> (none)</ td >
14
14
< td > Duration</ td >
15
15
< td > The maximum time the JobManager will wait with evaluating previously observed events for rescaling (default: 0ms if checkpointing is disabled and %dx of the checkpointing interval if checkpointing is enabled).</ td >
Original file line number Diff line number Diff line change 87
87
< td > The size of the write buffer of JobEventStore. The content will be flushed to external file system once the buffer is full</ td >
88
88
</ tr >
89
89
< tr >
90
- < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-rescale -trigger</ h5 > </ td >
90
+ < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-scale -trigger</ h5 > </ td >
91
91
< td style ="word-wrap: break-word; "> (none)</ td >
92
92
< td > Duration</ td >
93
93
< td > The maximum time the JobManager will wait with evaluating previously observed events for rescaling (default: 0ms if checkpointing is disabled and %dx of the checkpointing interval if checkpointing is enabled).</ td >
Original file line number Diff line number Diff line change 9
9
</ thead >
10
10
< tbody >
11
11
< tr >
12
- < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-rescale -trigger</ h5 > </ td >
12
+ < td > < h5 > jobmanager.adaptive-scheduler.max-delay-for-scale -trigger</ h5 > </ td >
13
13
< td style ="word-wrap: break-word; "> (none)</ td >
14
14
< td > Duration</ td >
15
15
< td > The maximum time the JobManager will wait with evaluating previously observed events for rescaling (default: 0ms if checkpointing is disabled and %dx of the checkpointing interval if checkpointing is enabled).</ td >
Original file line number Diff line number Diff line change @@ -578,8 +578,8 @@ public InlineElement getDescription() {
578
578
Documentation .Sections .EXPERT_SCHEDULING ,
579
579
Documentation .Sections .ALL_JOB_MANAGER
580
580
})
581
- public static final ConfigOption <Duration > MAXIMUM_DELAY_FOR_RESCALE_TRIGGER =
582
- key ("jobmanager.adaptive-scheduler.max-delay-for-rescale -trigger" )
581
+ public static final ConfigOption <Duration > MAXIMUM_DELAY_FOR_SCALE_TRIGGER =
582
+ key ("jobmanager.adaptive-scheduler.max-delay-for-scale -trigger" )
583
583
.durationType ()
584
584
.noDefaultValue ()
585
585
.withDescription (
Original file line number Diff line number Diff line change 145
145
import java .util .concurrent .TimeUnit ;
146
146
import java .util .function .Function ;
147
147
148
- import static org .apache .flink .configuration .JobManagerOptions .MAXIMUM_DELAY_FOR_RESCALE_TRIGGER ;
148
+ import static org .apache .flink .configuration .JobManagerOptions .MAXIMUM_DELAY_FOR_SCALE_TRIGGER ;
149
149
import static org .apache .flink .configuration .JobManagerOptions .MIN_PARALLELISM_INCREASE ;
150
150
import static org .apache .flink .runtime .executiongraph .ExecutionGraphUtils .isAnyOutputBlocking ;
151
151
@@ -245,8 +245,7 @@ public static Settings of(
245
245
scalingIntervalMax ,
246
246
configuration .get (MIN_PARALLELISM_INCREASE ),
247
247
configuration .get (
248
- MAXIMUM_DELAY_FOR_RESCALE_TRIGGER ,
249
- maximumDelayForRescaleTriggerDefault ));
248
+ MAXIMUM_DELAY_FOR_SCALE_TRIGGER , maximumDelayForRescaleTriggerDefault ));
250
249
}
251
250
252
251
private final SchedulerExecutionMode executionMode ;
Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ void testProperConfiguration() {
48
48
configuration .set (JobManagerOptions .SCHEDULER_SCALING_INTERVAL_MIN , scalingIntervalMin );
49
49
configuration .set (JobManagerOptions .SCHEDULER_SCALING_INTERVAL_MAX , scalingIntervalMax );
50
50
configuration .set (
51
- JobManagerOptions .MAXIMUM_DELAY_FOR_RESCALE_TRIGGER , maximumDelayForRescaleTrigger );
51
+ JobManagerOptions .MAXIMUM_DELAY_FOR_SCALE_TRIGGER , maximumDelayForRescaleTrigger );
52
52
53
53
final DefaultRescaleManager testInstance =
54
54
DefaultRescaleManager .Factory .fromSettings (
You can’t perform that action at this time.
0 commit comments