Update LoadNodeUtils.java

Author: healchow

inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/LoadNodeUtils.java

@@ -230,47 +230,57 @@ public static HbaseLoadNode createLoadNode(HbaseSinkResponse hbaseSinkResponse)
     }
 
     /**
-     * create postgres load node
+     * Create postgres load node from response.
      *
-     * @param postgresSinkResponse postgresSinkResponse
+     * @param postgresSinkResponse postgres response
      * @return postgres load node
      */
     public static PostgresLoadNode createLoadNode(PostgresSinkResponse postgresSinkResponse) {
         List<SinkFieldResponse> sinkFieldResponses = postgresSinkResponse.getFieldList();
-
         String name = postgresSinkResponse.getSinkName();
         List<FieldInfo> fields = sinkFieldResponses.stream()
-                .map(sinkFieldResponse -> FieldInfoUtils.parseSinkFieldInfo(sinkFieldResponse,
-                        name))
+                .map(fieldResponse -> FieldInfoUtils.parseSinkFieldInfo(fieldResponse, name))
                 .collect(Collectors.toList());
         List<FieldRelationShip> fieldRelationShips = parseSinkFields(sinkFieldResponses, name);
-        return new PostgresLoadNode(postgresSinkResponse.getSinkName(),
-                postgresSinkResponse.getSinkName(),
-                fields, fieldRelationShips, null, null, 1,
-                null, postgresSinkResponse.getJdbcUrl(), postgresSinkResponse.getUsername(),
+        return new PostgresLoadNode(
+                name,
+                name,
+                fields,
+                fieldRelationShips,
+                null,
+                null,
+                1,
+                null,
+                postgresSinkResponse.getJdbcUrl(),
+                postgresSinkResponse.getUsername(),
                 postgresSinkResponse.getPassword(),
                 postgresSinkResponse.getDbName() + "." + postgresSinkResponse.getTableName(),
                 postgresSinkResponse.getPrimaryKey());
     }
 
     /**
-     * create clickHouse load node
+     * Create ClickHouse load node
      *
-     * @param clickHouseSinkResponse clickHouseSinkResponse
-     * @return
+     * @param clickHouseSinkResponse clickhouse response
+     * @return clickhouse load node
      */
     public static ClickHouseLoadNode createLoadNode(ClickHouseSinkResponse clickHouseSinkResponse) {
         List<SinkFieldResponse> sinkFieldResponses = clickHouseSinkResponse.getFieldList();
         String name = clickHouseSinkResponse.getSinkName();
         List<FieldInfo> fields = sinkFieldResponses.stream()
-                .map(sinkFieldResponse -> FieldInfoUtils.parseSinkFieldInfo(sinkFieldResponse,
-                        name))
+                .map(fieldResponse -> FieldInfoUtils.parseSinkFieldInfo(fieldResponse, name))
                 .collect(Collectors.toList());
         List<FieldRelationShip> fieldRelationShips = parseSinkFields(sinkFieldResponses, name);
-        return new ClickHouseLoadNode(clickHouseSinkResponse.getSinkName(),
-                clickHouseSinkResponse.getSinkName(),
-                fields, fieldRelationShips, null, null, 1,
-                null, clickHouseSinkResponse.getTableName(),
+        return new ClickHouseLoadNode(
+                name,
+                name,
+                fields,
+                fieldRelationShips,
+                null,
+                null,
+                1,
+                null,
+                clickHouseSinkResponse.getTableName(),
                 clickHouseSinkResponse.getJdbcUrl(),
                 clickHouseSinkResponse.getUsername(),
                 clickHouseSinkResponse.getPassword());