(paimon-webui) branch main updated: [Bugfix] Fix exception of failing CDC job submission (#240)

[nicholasjiang]

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 01eb4ec  [Bugfix] Fix exception of failing CDC job submission (#240)
01eb4ec is described below

commit 01eb4ec6110e681da202534a1141988d3f9875c1
Author: yangyang zhong <35210666+hdyg...@users.noreply.github.com>
AuthorDate: Sun May 26 10:54:26 2024 +0800

    [Bugfix] Fix exception of failing CDC job submission (#240)
---
 .../action/context/factory/MysqlSyncTableActionContextFactory.java  | 4 ++--
 .../org/apache/paimon/web/api/enums/FlinkCdcDataSourceType.java     | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/paimon-web-api/src/main/java/org/apache/paimon/web/api/action/context/factory/MysqlSyncTableActionContextFactory.java
 
b/paimon-web-api/src/main/java/org/apache/paimon/web/api/action/context/factory/MysqlSyncTableActionContextFactory.java
index 8b315e1..f67f0e1 100644
--- 
a/paimon-web-api/src/main/java/org/apache/paimon/web/api/action/context/factory/MysqlSyncTableActionContextFactory.java
+++ 
b/paimon-web-api/src/main/java/org/apache/paimon/web/api/action/context/factory/MysqlSyncTableActionContextFactory.java
@@ -36,12 +36,12 @@ public class MysqlSyncTableActionContextFactory implements 
FlinkCdcActionContext
 
     @Override
     public String sourceType() {
-        return FlinkCdcDataSourceType.MYSQL.name();
+        return FlinkCdcDataSourceType.MYSQL.getType();
     }
 
     @Override
     public String targetType() {
-        return FlinkCdcDataSourceType.PAIMON.name();
+        return FlinkCdcDataSourceType.PAIMON.getType();
     }
 
     @Override
diff --git 
a/paimon-web-api/src/main/java/org/apache/paimon/web/api/enums/FlinkCdcDataSourceType.java
 
b/paimon-web-api/src/main/java/org/apache/paimon/web/api/enums/FlinkCdcDataSourceType.java
index bf0a286..5d8a863 100644
--- 
a/paimon-web-api/src/main/java/org/apache/paimon/web/api/enums/FlinkCdcDataSourceType.java
+++ 
b/paimon-web-api/src/main/java/org/apache/paimon/web/api/enums/FlinkCdcDataSourceType.java
@@ -26,9 +26,9 @@ public enum FlinkCdcDataSourceType {
     MYSQL("MySQL"),
     PAIMON("Paimon");
 
-    private final String name;
+    private final String type;
 
-    FlinkCdcDataSourceType(String name) {
-        this.name = name;
+    FlinkCdcDataSourceType(String type) {
+        this.type = type;
     }
 }