[Chore] Use united variable name

Author: npofsi

dolphinscheduler-task-plugin/dolphinscheduler-task-grpc/src/main/java/org/apache/dolphinscheduler/plugin/task/grpc/GrpcParameters.java

@@ -17,6 +17,7 @@
 
 package org.apache.dolphinscheduler.plugin.task.grpc;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParameters;
 
 import org.apache.commons.lang3.StringUtils;
@@ -42,15 +43,12 @@ public class GrpcParameters extends AbstractParameters {
 
     private String condition;
 
-    /**
-     * Connect Timeout
-     * Unit: ms
-     */
-    private int connectTimeout = 0;
+    @JsonProperty("connectTimeout")
+    private long connectTimeoutMs = 0L;
 
     @Override
     public boolean checkParameters() {
-        if (StringUtils.isEmpty(url) || connectTimeout <= 0)
+        if (StringUtils.isEmpty(url) || connectTimeoutMs <= 0)
             return false;
         return true;
     }

dolphinscheduler-task-plugin/dolphinscheduler-task-grpc/src/main/java/org/apache/dolphinscheduler/plugin/task/grpc/GrpcTask.java

@@ -76,7 +76,7 @@ public void handle(TaskCallBack taskCallBack) throws TaskException {
                     JSONDescriptorHelper.FileDescFromJSON(grpcParameters.getGrpcServiceDefinitionJSON());
             GrpcDynamicService stubService = new GrpcDynamicService(channel, fileDesc);
             DynamicMessage message = stubService.call(grpcParameters.getMethodName(), grpcParameters.getMessage(),
-                    grpcParameters.getConnectTimeout());
+                    grpcParameters.getConnectTimeoutMs());
             Printer printer = JsonFormat.printer().omittingInsignificantWhitespace();
             addDefaultOutput(printer.print(message));
         } catch (StatusRuntimeException statusre) {

dolphinscheduler-task-plugin/dolphinscheduler-task-grpc/src/test/java/org/apache/dolphinscheduler/plugin/task/grpc/GrpcParametersTest.java

@@ -46,7 +46,7 @@ public void testGenerator() throws IOException {
                 "\"connectTimeout\":\"10000\"" +
                 "}";
         GrpcParameters grpcParameters = JSONUtils.parseObject(paramData, GrpcParameters.class);
-        Assertions.assertEquals(10000, grpcParameters.getConnectTimeout());
+        Assertions.assertEquals(10000, grpcParameters.getConnectTimeoutMs());
         Assertions.assertEquals("127.0.0.1:50010", grpcParameters.getUrl());
         Assertions.assertEquals("TaskTester/TestOK", grpcParameters.getMethodName());
         Assertions.assertEquals("{ \"username\":\"test username\" }", grpcParameters.getMessage());
@@ -70,7 +70,7 @@ public void testCheckParameters() throws IOException {
                 "}";
         GrpcParameters grpcParameters = JSONUtils.parseObject(paramData, GrpcParameters.class);
         Assertions.assertTrue(grpcParameters.checkParameters());
-        Assertions.assertEquals(10000, grpcParameters.getConnectTimeout());
+        Assertions.assertEquals(10000, grpcParameters.getConnectTimeoutMs());
         Assertions.assertEquals("127.0.0.1:50010", grpcParameters.getUrl());
         Assertions.assertEquals("TaskTester/TestOK", grpcParameters.getMethodName());
         Assertions.assertEquals("{ \"username\":\"test username\" }", grpcParameters.getMessage());
@@ -93,7 +93,7 @@ public void testCheckValues() throws IOException {
                 "\"connectTimeout\":\"10000\"" +
                 "}";
         GrpcParameters grpcParameters = JSONUtils.parseObject(paramData, GrpcParameters.class);
-        Assertions.assertEquals(10000, grpcParameters.getConnectTimeout());
+        Assertions.assertEquals(10000, grpcParameters.getConnectTimeoutMs());
         Assertions.assertEquals("127.0.0.1:50010", grpcParameters.getUrl());
         Assertions.assertEquals("TaskTester/TestOK", grpcParameters.getMethodName());
         Assertions.assertEquals("{ \"username\":\"test username\" }", grpcParameters.getMessage());

dolphinscheduler-task-plugin/dolphinscheduler-task-grpc/src/test/java/org/apache/dolphinscheduler/plugin/task/grpc/GrpcParserTest.java

@@ -304,7 +304,7 @@ private String generateGrpcParameters(String url, String methodName, String requ
         grpcParameters.setMessage(requestMessage);
         grpcParameters.setGrpcCheckCondition(grpcCheckCondition);
         grpcParameters.setCondition(condition);
-        grpcParameters.setConnectTimeout(10000);
+        grpcParameters.setConnectTimeoutMs(10000);
         return mapper.writeValueAsString(grpcParameters);
     }
 

dolphinscheduler-task-plugin/dolphinscheduler-task-grpc/src/test/java/org/apache/dolphinscheduler/plugin/task/grpc/GrpcTaskTest.java

@@ -215,7 +215,7 @@ private String generateGrpcParameters(String url, String methodName, String requ
         grpcParameters.setMessage(requestMessage);
         grpcParameters.setGrpcCheckCondition(grpcCheckCondition);
         grpcParameters.setCondition(condition);
-        grpcParameters.setConnectTimeout(10000);
+        grpcParameters.setConnectTimeoutMs(10000);
         return mapper.writeValueAsString(grpcParameters);
     }