Skip to content

Commit a59d738

Browse files
och5351XCompRocMarshal
committed
[FLINK-38899][runtime-web] Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled
Co-authored-by: Matthias Pohl <mpohl@confluent.io> Co-authored-by: Yuepeng Pan <hipanyuepeng@gmail.com>
1 parent 9b2a112 commit a59d738

5 files changed

Lines changed: 589 additions & 8 deletions

File tree

flink-runtime-web/web-dashboard/src/app/interfaces/job-rescales.ts

Lines changed: 58 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,64 @@
1616
* limitations under the License.
1717
*/
1818

19-
export interface RescalesConfig {
19+
export type RescalesHistory = BriefJobRescaleDetails[];
20+
21+
export interface BriefJobRescaleDetails {
22+
rescaleUuid: string;
23+
resourceRequirementsUuid: string;
24+
rescaleAttemptId: number;
25+
vertices: { [jobVertexId: string]: VertexParallelismRescaleInfo };
26+
slots: { [slotSharingGroupId: string]: SlotSharingGroupRescaleInfo };
27+
schedulerStates: SchedulerState[];
28+
startTimestampInMillis: number;
29+
endTimestampInMillis: number;
30+
terminalState: string;
31+
triggerCause: string;
32+
terminatedReason: string;
33+
}
34+
35+
export interface JobRescaleDetails extends BriefJobRescaleDetails {}
36+
37+
export interface VertexParallelismRescaleInfo {
38+
jobVertexId: string;
39+
jobVertexName: string;
40+
slotSharingGroupId: string;
41+
slotSharingGroupName: string;
42+
desiredParallelism: number;
43+
sufficientParallelism: number;
44+
preRescaleParallelism: number;
45+
postRescaleParallelism: number;
46+
}
47+
48+
export interface SlotSharingGroupRescaleInfo {
49+
slotSharingGroupId: string;
50+
slotSharingGroupName: string;
51+
requestResourceProfile: ResourceProfileInfo;
52+
desiredSlots: number;
53+
minimalRequiredSlots: number;
54+
preRescaleSlots: number;
55+
postRescaleSlots: number;
56+
acquiredResourceProfile: ResourceProfileInfo;
57+
}
58+
59+
export interface ResourceProfileInfo {
60+
cpuCores: number;
61+
taskHeapMemory: number;
62+
taskOffHeapMemory: number;
63+
managedMemory: number;
64+
networkMemory: number;
65+
extendedResources: { [key: string]: unknown };
66+
}
67+
68+
export interface SchedulerState {
69+
state: string;
70+
enterTimestampInMillis: number;
71+
leaveTimestampInMillis: number;
72+
durationInMillis: number;
73+
stringifiedException: string;
74+
}
75+
76+
export interface JobRescaleConfigInfo {
2077
rescaleHistoryMax: number;
2178
schedulerExecutionMode: string;
2279
submissionResourceWaitTimeoutInMillis: number;

0 commit comments

Comments
 (0)