in streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEdit.ts [55:115]
function handleResetApplication() {
let parallelism: Nullable<number> = null;
let slot: Nullable<number> = null;
const fieldValueOptions = {
totalItem: {},
tmOptionsItem: {},
jmOptionsItem: {},
};
for (const k in defaultOptions) {
let v = defaultOptions[k];
if (isString(v)) v = v.replace(/[k|m|g]b$/g, '');
const key = optionsValueMapping.get(k);
if (key) {
if (
k === 'jobmanager.memory.flink.size' ||
k === 'taskmanager.memory.flink.size' ||
k === 'jobmanager.memory.process.size' ||
k === 'taskmanager.memory.process.size'
) {
memoryItems.totalItems.push(key);
fieldValueOptions.totalItem[key] = parseInt(v);
} else {
if (k.startsWith('jobmanager.memory.')) {
memoryItems.jmMemoryItems.push(key);
if (k === 'jobmanager.memory.jvm-overhead.fraction') {
fieldValueOptions.jmOptionsItem[key] = parseFloat(v);
} else {
fieldValueOptions.jmOptionsItem[key] = parseInt(v);
}
}
if (k.startsWith('taskmanager.memory.')) {
memoryItems.tmMemoryItems.push(key);
if (
k === 'taskmanager.memory.managed.fraction' ||
k === 'taskmanager.memory.jvm-overhead.fraction'
) {
fieldValueOptions.tmOptionsItem[key] = parseFloat(v);
} else {
fieldValueOptions.tmOptionsItem[key] = parseInt(v);
}
}
}
} else {
if (k === 'taskmanager.numberOfTaskSlots') {
slot = parseInt(v);
}
if (k === 'parallelism.default') {
parallelism = parseInt(v);
}
}
}
return {
parallelism,
slot,
totalOptions: memoryItems.totalItems,
jmOptions: memoryItems.jmMemoryItems,
tmOptions: memoryItems.tmMemoryItems,
...fieldValueOptions,
};
}