add flink status monitor

Author: baisui1981

tis-datax/tis-datax-dolphinscheduler-plugin/src/main/java/com/qlangtech/tis/plugin/datax/doplinscheduler/DSWorkflowPayload.java

@@ -27,7 +27,6 @@
 import com.qlangtech.tis.coredefine.module.action.DistributeJobTriggerBuildResult;
 import com.qlangtech.tis.dao.ICommonDAOContext;
 import com.qlangtech.tis.datax.IDataxProcessor;
-import com.qlangtech.tis.datax.StoreResourceType;
 import com.qlangtech.tis.datax.job.DataXJobWorker;
 import com.qlangtech.tis.exec.ExecutePhaseRange;
 import com.qlangtech.tis.fullbuild.IFullBuildContext;
@@ -396,7 +395,7 @@ private void innerSaveJob(
         //  URL url = new URL(this.exportCfg.processDefinition().toString());
         List<PostParam> params = Lists.newArrayList();
         // params.add(new PostParam("projectCode", 117370558003456l));
-        params.add(new PostParam("name", this.exportCfg.processName));
+        params.add(new PostParam("name", this.exportCfg.name));
         params.add(new PostParam("description", this.exportCfg.processDescription));
         params.add(new PostParam("globalParams", "[]"));
         params.add(new PostParam("locations", JsonUtil.toString(locationArray)));

tis-datax/tis-datax-dolphinscheduler-plugin/src/main/java/com/qlangtech/tis/plugin/datax/doplinscheduler/export/ExportTISPipelineToDolphinscheduler.java

@@ -66,8 +66,8 @@ public class ExportTISPipelineToDolphinscheduler extends DefaultDataXProcessorMa
     public static final String FIELD_PROJECT_CODE = "projectCode";
 
 
-    @FormField(ordinal = 1, identity = true, type = FormFieldType.INPUTTEXT, validate = {Validator.require, Validator.identity, Validator.forbid_start_with_number})
-    public String processName;
+//    @FormField(ordinal = 1, identity = true, type = FormFieldType.INPUTTEXT, validate = {Validator.require, Validator.identity, Validator.forbid_start_with_number})
+//    public String processName;
 
     @FormField(ordinal = 2, type = FormFieldType.SELECTABLE, validate = {Validator.require})
     public String dsEndpoint;
@@ -126,10 +126,10 @@ public DolphinSchedulerURLBuilder processDefinition() {
         //    return new StringBuffer("http://192.168.28.201:12345/dolphinscheduler/projects/" + this.projectCode + "/process-definition");
     }
 
-    @Override
-    public String identityValue() {
-        return this.processName;
-    }
+//    @Override
+//    public String identityValue() {
+//        return this.processName;
+//    }
 
     public DolphinSchedulerEndpoint getDSEndpoint() {
         DolphinSchedulerEndpoint dsEndpoint = ParamsConfig.getItem(this.dsEndpoint, DolphinSchedulerEndpoint.DISPLAY_NAME);
@@ -362,7 +362,7 @@ protected boolean validateAll(IControlMsgHandler msgHandler, Context context, Po
                  ********************************************************/
                 DolphinSchedulerResponse response = export.processDefinition()
                         .appendSubPath("query-by-name")
-                        .appendQueryParam("name", export.processName).applyGet();
+                        .appendQueryParam("name", export.name).applyGet();
                 if (!response.isSuccess()) {
                     Status status = Status.findStatusBy(response.getCode());
                     switch (status) {
@@ -386,7 +386,7 @@ protected boolean validateAll(IControlMsgHandler msgHandler, Context context, Po
                 //http://192.168.28.201:12345/dolphinscheduler/swagger-ui/index.html?language=zh_CN&lang=cn#/%E6%B5%81%E7%A8%8B%E5%AE%9A%E4%B9%89%E7%9B%B8%E5%85%B3%E6%93%8D%E4%BD%9C/verifyProcessDefinitionName
                 DolphinSchedulerResponse response = export.processDefinition()
                         .appendSubPath("verify-name")
-                        .appendQueryParam("name", export.processName).applyGet();
+                        .appendQueryParam("name", export.name).applyGet();
 
                 if (!response.isSuccess()) {
                     Status status = Status.findStatusBy(response.getCode());

tis-datax/tis-datax-dolphinscheduler-plugin/src/main/resources/com/qlangtech/tis/plugin/datax/doplinscheduler/export/ExportTISPipelineToDolphinscheduler.json

@@ -27,7 +27,7 @@
     "dftVal": "Default",
     "help": "对应的dolphinscheduler中工作流执行过程中需要回调TIS，设置相应参数"
   },
-  "processName": {
+  "name": {
     "label": "工作流名称",
     "help": "对应的dolphinscheduler中工作流名称，确保同一项目下工作流名称唯一，不能重复",
     "dftVal": "com.qlangtech.tis.plugin.datax.doplinscheduler.export.ExportTISPipelineToDolphinscheduler.dftProcessName():uncache_true"

tis-datax/tis-datax-kingbase-plugin/src/main/resources/com/qlangtech/tis/plugin/ds/kingbase/KingBaseDataSourceFactory.json

@@ -6,5 +6,8 @@
   "dispatch": {
     "label": "读写分离",
     "dftVal": "off"
+  },
+  "port": {
+    "dftVal": 4321
   }
 }

tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/alert/AddMonitorForEvents.java

@@ -26,8 +26,8 @@ public class AddMonitorForEvents extends DefaultDataXProcessorManipulate impleme
 
     private static final String KEY_ALERT_CHANNEL = "alertChannel";
 
-    @FormField(ordinal = 1, identity = true, type = FormFieldType.INPUTTEXT, validate = {Validator.require, Validator.identity, Validator.forbid_start_with_number})
-    public String name;
+//    @FormField(ordinal = 1, identity = true, type = FormFieldType.INPUTTEXT, validate = {Validator.require, Validator.identity, Validator.forbid_start_with_number})
+//    public String name;
 
     /**
      * 是否启效
@@ -95,10 +95,10 @@ protected void afterManipuldateProcess(IPluginContext pluginContext, Optional<Co
 
     }
 
-    @Override
-    public String identityValue() {
-        return this.name;
-    }
+//    @Override
+//    public String identityValue() {
+//        return this.name;
+//    }
 
     @TISExtension
     public static class DefaultDesc extends DefaultDataXProcessorManipulate.BasicDesc implements IEndTypeGetter {