[Improvement] The query module obtains the cluster name through deplo…

…ymentMode (#482)
apache · Jul 10, 2024 · d049fd1 · d049fd1
1 parent 14b46b6
commit d049fd1
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 3 deletions.
diff --git a/paimon-web-ui/src/api/models/cluster/index.ts b/paimon-web-ui/src/api/models/cluster/index.ts
@@ -30,7 +30,18 @@ export function getClusterList() {
 }
 
 /**
- * # List Cluster by ClusterType
+ * # List Cluster by Deployment Mode
+ */
+export function getClusterListByDeploymentMode(deploymentMode: string, pageNum: number, pageSize: number) {
+  return httpRequest.get('/cluster/list', {
+    deploymentMode,
+    pageNum,
+    pageSize,
+  })
+}
+
+/**
+ * # List Cluster by Type
  */
 export function getClusterListByType(type: string, pageNum: number, pageSize: number) {
   return httpRequest.get('/cluster/list', {

diff --git a/paimon-web-ui/src/views/playground/components/query/components/debugger/index.tsx b/paimon-web-ui/src/views/playground/components/query/components/debugger/index.tsx
@@ -20,7 +20,7 @@ import { FormatAlignLeftOutlined } from '@vicons/material'
 import { NInput, useMessage } from 'naive-ui'
 
 import styles from './index.module.scss'
-import { getClusterListByType } from '@/api/models/cluster'
+import { getClusterListByDeploymentMode } from '@/api/models/cluster'
 import type { Cluster } from '@/api/models/cluster/types'
 import type { JobSubmitDTO } from '@/api/models/job/types/job'
 import { createRecord, stopJob, submitJob } from '@/api/models/job'
@@ -153,7 +153,8 @@ export default defineComponent({
     }
 
     function getClusterData() {
-      getClusterListByType(debuggerVariables.conditionValue, 1, Number.MAX_SAFE_INTEGER).then((response) => {
+      const deploymentMode = debuggerVariables.conditionValue === 'Flink' ? 'flink-sql-gateway' : debuggerVariables.conditionValue
+      getClusterListByDeploymentMode(deploymentMode, 1, Number.MAX_SAFE_INTEGER).then((response) => {
         if (response && response.data) {
           const clusterList = response.data as Cluster[]
           debuggerVariables.clusterOptions = clusterList.map(cluster => ({