diff --git a/streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts b/streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts index 2bcd56657f..84658abf29 100644 --- a/streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts +++ b/streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts @@ -487,6 +487,69 @@ const options = [ } }, }, + { + key: 'taskmanager.memory.network.max', + name: 'taskmanager.memory.network.max', + placeholder: 'Max Network Memory size for TaskExecutors', + description: + 'This biggest Network Memory is used for allocation of network buffers', + unit: 'mb', + group: 'taskmanager-memory', + type: 'number', + min: 64, + max: 1024, + step: 1, + defaultValue: 1024, + validator: (_rule, value, callback) => { + if (!value) { + callback(new Error('memory.network.max is required or you can delete this option')); + } else { + callback(); + } + }, + }, + { + key: 'taskmanager.memory.network.min', + name: 'taskmanager.memory.network.min', + placeholder: 'Min Network Memory size for TaskExecutors', + description: + 'This minimum Network Memory is used for allocation of network buffers', + unit: 'mb', + group: 'taskmanager-memory', + type: 'number', + min: 64, + max: 1024, + step: 1, + defaultValue: 64, + validator: (_rule, value, callback) => { + if (!value) { + callback(new Error('memory.network.min is required or you can delete this option')); + } else { + callback(); + } + }, + }, + { + key: 'taskmanager.memory.network.fraction', + name: 'taskmanager.memory.network.fraction', + placeholder: 'Fraction of Network Memory size for TaskExecutors', + description: + 'The fraction of Network Memory size is used for allocation of network buffers', + unit: 'mb', + group: 'taskmanager-memory', + type: 'number', + min: 0.1, + max: 1, + step: 0.1, + defaultValue: 0.1, + validator: (_rule, value, callback) => { + if (!value) { + callback(new Error('memory.network.fraction is required or you can delete this option')); + } else { + callback(); + } + }, + }, ]; const optionsKeyMapping = new Map();