This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch flink-args-option in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit f7cdb02f143e74698b1315ef9e66842ff10b48da Author: benjobs <[email protected]> AuthorDate: Wed Nov 15 22:06:41 2023 +0800 [ISSUE-3330][Feature] add taskmanager.memory.network to TM Memory Options --- .../src/views/flink/app/data/option.ts | 60 ++++++++++++++++++++++ 1 file changed, 60 insertions(+) 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 2bcd56657..54cb399cf 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,66 @@ 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<string, Recordable>();
