This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.2 by this push:
new b71dae7cc [ISSUE-3330][Feature] add taskmanager.memory.network to TM
Memory Options (#3344)
b71dae7cc is described below
commit b71dae7ccb6786bbc512435e4e399df5a85f9a7b
Author: benjobs <[email protected]>
AuthorDate: Wed Nov 15 22:07:40 2023 +0800
[ISSUE-3330][Feature] add taskmanager.memory.network to TM Memory Options
(#3344)
---
.../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>();