add host property for StandaloneFlinkDeployingAIAssistSupport

Author: baisui1981

tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/clustertype/StandaloneFlinkDeployingAIAssistSupport.java

@@ -99,7 +99,10 @@ public class StandaloneFlinkDeployingAIAssistSupport extends AIAssistSupport<Sta
     @FormField(ordinal = 4, type = FormFieldType.MEMORY_SIZE_OF_MEGA, validate = {Validator.require})
     public com.qlangtech.tis.plugin.MemorySize tmMemory;
 
-    @FormField(ordinal = 5, type = FormFieldType.INT_NUMBER, advance = true, validate = {Validator.require, Validator.integer})
+    @FormField(ordinal = 5, type = FormFieldType.INPUTTEXT, advance = true, validate = {Validator.require, Validator.hostWithoutPort})
+    public String host;
+
+    @FormField(ordinal = 6, type = FormFieldType.INT_NUMBER, advance = true, validate = {Validator.require, Validator.integer})
     public Integer port;
 
 
@@ -492,7 +495,8 @@ private Standalone createNewFlinkCluster(IAgentContext agentContext, IPluginCont
         FlinkCluster flinkCluster = new FlinkCluster();
         IdentityName newClusterId = IdentityName.createNewPrimaryFieldValue(IFlinkCluster.KEY_DISPLAY_NAME, clusters);
         flinkCluster.name = newClusterId.identityValue();
-        flinkCluster.jobManagerAddress = LOCAL_HOST_VALUE + ":" + this.port;
+       // com.qlangtech.tis.realtime.utils.NetUtils.getHost()
+        flinkCluster.jobManagerAddress = this.host + ":" + this.port;
         flinkCluster.maxRetry = FLINK_DEFAULT_RETRY_MAX_ATTEMPTS;
         flinkCluster.retryDelay = RestOptions.RETRY_DELAY.defaultValue().toMillis();
 
@@ -584,6 +588,14 @@ public boolean validateSlot(IFieldErrorHandler msgHandler, Context context, Stri
         }
 
 
+        public boolean validateHost(IFieldErrorHandler msgHandler, Context context, String fieldName, String value) {
+            if (NetUtils.isReachable(value)) {
+                msgHandler.addFieldError(context, fieldName,  "地址不可用");
+                return false;
+            }
+            return true;
+        }
+
 //        public boolean validatePort(IFieldErrorHandler msgHandler, Context context, String fieldName, String value) {
 //            if (NetUtils.isPortAvailable(LOCAL_HOST_VALUE, Integer.parseInt(value))) {
 //                msgHandler.addFieldError(context, fieldName, "端口：" + value + "不可用，或者已被占用");

tis-incr/tis-realtime-flink/src/main/resources/com/qlangtech/plugins/incr/flink/launch/clustertype/StandaloneFlinkDeployingAIAssistSupport.json

@@ -21,5 +21,10 @@
     "label": "Flink Port",
     "dftVal": "8081",
     "help": "Flink 暴露的的REST API Http 端口"
+  },
+  "host": {
+    "label": "主机地址",
+    "dftVal": "com.qlangtech.tis.realtime.utils.NetUtils.getHost()",
+    "help": "部署flink所在的地址，需要是与TIS控制台同一个主机节点地址"
   }
 }