(incubator-streampark) branch dev updated: [ISSUE-3330][Feature]add taskmanager.memory.network to TM Memory Options (#3340)

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 93330aadc [ISSUE-3330][Feature]add taskmanager.memory.network to TM 
Memory Options (#3340)
93330aadc is described below

commit 93330aadc53d4c21f22124f22f1172b5cfb9bddb
Author: didiaode18 <563646...@qq.com>
AuthorDate: Wed Nov 15 11:34:32 2023 +0800

    [ISSUE-3330][Feature]add taskmanager.memory.network to TM Memory Options 
(#3340)
---
 .../src/views/flink/app/data/option.ts             | 63 ++++++++++++++++++++++
 1 file changed, 63 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..84658abf2 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<string, Recordable>();