(paimon-webui) branch main updated: [Improvement] Support selecting a session cluster when submitting CDC jobs (#291)

[ni...@apache.org]

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

nicholasjiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-webui.git


The following commit(s) were added to refs/heads/main by this push:
     new e25fc45c [Improvement] Support selecting a session cluster when submitting CDC jobs (#291)
e25fc45c is described below

commit e25fc45cf5233d211a6fa3508206ae7966fb0038
Author: yangyang zhong <35...@users.noreply.github.com>
AuthorDate: Thu Jun 6 16:23:51 2024 +0800

    [Improvement] Support selecting a session cluster when submitting CDC jobs (#291)
---
 paimon-web-ui/src/form-lib/cdc/use-submit-cdc-job.ts | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/paimon-web-ui/src/form-lib/cdc/use-submit-cdc-job.ts b/paimon-web-ui/src/form-lib/cdc/use-submit-cdc-job.ts
index e7d6e318..ec86cad2 100644
--- a/paimon-web-ui/src/form-lib/cdc/use-submit-cdc-job.ts
+++ b/paimon-web-ui/src/form-lib/cdc/use-submit-cdc-job.ts
@@ -16,7 +16,10 @@ specific language governing permissions and limitations
 under the License. */
 
 import type { CdcJobSubmit } from '@/api/models/cdc'
+import { getClusterListByType } from '@/api/models/cluster'
+import type { Cluster } from '@/api/models/cluster/types'
 import type { IJsonItem } from '@/components/dynamic-form/types'
+import type { SelectOption } from 'naive-ui'
 
 export function useSumbitCdcJob(item: any) {
   const { t } = useLocaleHooks()
@@ -25,15 +28,25 @@ export function useSumbitCdcJob(item: any) {
     flinkSessionUrl: item.flinkSessionUrl,
   })
 
+  const flinkSessionClusterOptions =  ref<SelectOption[]>([])
+   getClusterListByType ('Flink', 1, Number.MAX_SAFE_INTEGER).then((response) => {
+    if (response && response.data) {
+      const clusterList = response.data as Cluster[]
+       flinkSessionClusterOptions.value = clusterList.map(cluster => ({
+        label: cluster.clusterName,
+        value: cluster.id.toString(),
+      }))
+    }})
   return {
     json: [
       {
-        type: 'input',
-        field: 'flinkSessionUrl',
+        type: 'select',
+        field: 'clusterId',
         name: t('common.flink_session_url'),
         props: {
           placeholder: '',
         },
+        options: flinkSessionClusterOptions,
         validate: {
           trigger: ['input', 'blur'],
           required: true,