This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new a5f3d7b08 [INLONG-7096][Dashboard] Selecting Pulsar MQ Optimization
(#7097)
a5f3d7b08 is described below
commit a5f3d7b08d37fa0e6d944c5061ca0c84424b6a67
Author: Lizhen <88174078+bluew...@users.noreply.github.com>
AuthorDate: Sat Dec 31 16:30:26 2022 +0800
[INLONG-7096][Dashboard] Selecting Pulsar MQ Optimization (#7097)
Co-authored-by: Charles Zhang <dockerzh...@apache.org>
---
inlong-dashboard/src/locales/cn.json | 1 +
inlong-dashboard/src/locales/en.json | 1 +
inlong-dashboard/src/metas/groups/defaults/Pulsar.ts | 3 ++-
.../src/pages/GroupDetail/DataStream/StreamItemModal.tsx | 8 ++++++++
4 files changed, 12 insertions(+), 1 deletion(-)
diff --git a/inlong-dashboard/src/locales/cn.json
b/inlong-dashboard/src/locales/cn.json
index a47a78004..d17d4a1ef 100644
--- a/inlong-dashboard/src/locales/cn.json
+++ b/inlong-dashboard/src/locales/cn.json
@@ -321,6 +321,7 @@
"meta.Group.Pulsar.Parallel": "并行",
"meta.Group.Pulsar.Serial": "顺序",
"meta.Group.Pulsar.PartitionNum": "Topic 分区数",
+ "meta.Group.Pulsar.PartitionExtra": "Topic 分区数，最高可配置 100",
"meta.Group.Pulsar.EnsembleSuffix": "节点数",
"meta.Group.Pulsar.EnsembleExtra": "Topic 保存到多少个节点，最高可配置10个",
"meta.Group.Pulsar.WriteQuorumSuffix": "副本数",
diff --git a/inlong-dashboard/src/locales/en.json
b/inlong-dashboard/src/locales/en.json
index d66986604..8ba00e92b 100644
--- a/inlong-dashboard/src/locales/en.json
+++ b/inlong-dashboard/src/locales/en.json
@@ -321,6 +321,7 @@
"meta.Group.Pulsar.Parallel": "Parallel",
"meta.Group.Pulsar.Serial": "Serial",
"meta.Group.Pulsar.PartitionNum": "Topic Part Nums",
+ "meta.Group.Pulsar.PartitionExtra": "The number of topic partitions, up to
100 can be configured",
"meta.Group.Pulsar.EnsembleSuffix": "Number of nodes",
"meta.Group.Pulsar.EnsembleExtra": "How many nodes are Topic saved to, up to
10 can be configured",
"meta.Group.Pulsar.WriteQuorumSuffix": "Number of copies",
diff --git a/inlong-dashboard/src/metas/groups/defaults/Pulsar.ts
b/inlong-dashboard/src/metas/groups/defaults/Pulsar.ts
index 3b4e4768a..7e6be1602 100644
--- a/inlong-dashboard/src/metas/groups/defaults/Pulsar.ts
+++ b/inlong-dashboard/src/metas/groups/defaults/Pulsar.ts
@@ -54,9 +54,10 @@ export default class PulsarGroup
type: 'inputnumber',
initialValue: 3,
rules: [{ required: true }],
+ extra: i18n.t('meta.Group.Pulsar.PartitionExtra'),
props: {
min: 1,
- max: 20,
+ max: 100,
precision: 0,
},
visible: values => values.queueModule === 'PARALLEL',
diff --git
a/inlong-dashboard/src/pages/GroupDetail/DataStream/StreamItemModal.tsx
b/inlong-dashboard/src/pages/GroupDetail/DataStream/StreamItemModal.tsx
index 2c78e0e31..9aff9cd21 100644
--- a/inlong-dashboard/src/pages/GroupDetail/DataStream/StreamItemModal.tsx
+++ b/inlong-dashboard/src/pages/GroupDetail/DataStream/StreamItemModal.tsx
@@ -52,6 +52,8 @@ const Comp: React.FC<Props> = ({ inlongGroupId,
inlongStreamId, mqType, ...modal
type: 'inputnumber',
label: i18n.t('meta.Group.TubeMq.NumberOfAccess'),
name: 'dailyRecords',
+ initialValue: 1,
+ isPro: true,
rules: [{ required: true }],
suffix: i18n.t('meta.Group.TubeMq.TenThousand/Day'),
props: {
@@ -64,6 +66,8 @@ const Comp: React.FC<Props> = ({ inlongGroupId,
inlongStreamId, mqType, ...modal
type: 'inputnumber',
label: i18n.t('meta.Group.TubeMq.AccessSize'),
name: 'dailyStorage',
+ initialValue: 10,
+ isPro: true,
rules: [{ required: true }],
suffix: i18n.t('meta.Group.TubeMq.GB/Day'),
props: {
@@ -76,6 +80,8 @@ const Comp: React.FC<Props> = ({ inlongGroupId,
inlongStreamId, mqType, ...modal
type: 'inputnumber',
label: i18n.t('meta.Group.TubeMq.AccessPeakPerSecond'),
name: 'peakRecords',
+ initialValue: 100,
+ isPro: true,
rules: [{ required: true }],
suffix: i18n.t('meta.Group.TubeMq.Stripe/Second'),
props: {
@@ -88,6 +94,8 @@ const Comp: React.FC<Props> = ({ inlongGroupId,
inlongStreamId, mqType, ...modal
type: 'inputnumber',
label: i18n.t('meta.Group.TubeMq.SingleStripMaximumLength'),
name: 'maxLength',
+ initialValue: 1024,
+ isPro: true,
rules: [{ required: true }],
suffix: 'Byte',
props: {
