[inlong] branch master updated: [INLONG-7355][Manager] Fix the problem of HiveDataNode cannot save the datapath (#7357)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 91b8be741 [INLONG-7355][Manager] Fix the problem of HiveDataNode 
cannot save the datapath (#7357)
91b8be741 is described below

commit 91b8be7410bb76e8c2be1172a5beef5042029f62
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Sun Feb 12 12:01:46 2023 +0800

    [INLONG-7355][Manager] Fix the problem of HiveDataNode cannot save the 
datapath (#7357)
---
 .../org/apache/inlong/manager/pojo/node/hive/HiveDataNodeDTO.java     | 4 ++--
 .../org/apache/inlong/manager/pojo/node/hive/HiveDataNodeInfo.java    | 2 +-
 .../org/apache/inlong/manager/pojo/node/hive/HiveDataNodeRequest.java | 2 +-
 .../org/apache/inlong/manager/service/sort/SortServiceImplTest.java   | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeDTO.java
index ea9d36c6b..5862788b9 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeDTO.java
@@ -50,7 +50,7 @@ public class HiveDataNodeDTO {
     private String hiveConfDir;
 
     @ApiModelProperty("HDFS default FS, such as: hdfs://127.0.0.1:9000")
-    private String hdfsPath;
+    private String dataPath;
 
     @ApiModelProperty("Hive warehouse path, such as: /user/hive/warehouse/")
     private String warehouse;
@@ -65,7 +65,7 @@ public class HiveDataNodeDTO {
         return HiveDataNodeDTO.builder()
                 .hiveVersion(request.getHiveVersion())
                 .hiveConfDir(request.getHiveConfDir())
-                .hdfsPath(request.getHdfsPath())
+                .dataPath(request.getDataPath())
                 .warehouse(request.getWarehouse())
                 .hdfsUgi(request.getHdfsUgi())
                 .build();
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeInfo.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeInfo.java
index 5c9bbc2fb..112c55b9c 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeInfo.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeInfo.java
@@ -48,7 +48,7 @@ public class HiveDataNodeInfo extends DataNodeInfo {
     private String hiveConfDir;
 
     @ApiModelProperty("HDFS default FS, such as: hdfs://127.0.0.1:9000")
-    private String hdfsPath;
+    private String dataPath;
 
     @ApiModelProperty("Hive warehouse path, such as: /user/hive/warehouse/")
     private String warehouse;
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeRequest.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeRequest.java
index d7c4d6902..df963becb 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeRequest.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/hive/HiveDataNodeRequest.java
@@ -43,7 +43,7 @@ public class HiveDataNodeRequest extends DataNodeRequest {
     private String hiveConfDir;
 
     @ApiModelProperty("HDFS default FS, such as: hdfs://127.0.0.1:9000")
-    private String hdfsPath;
+    private String dataPath;
 
     @ApiModelProperty("Hive warehouse path, such as: /user/hive/warehouse/")
     private String warehouse;
diff --git 
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java
 
b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java
index 17ee08065..2338d092e 100644
--- 
a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java
+++ 
b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java
@@ -269,7 +269,7 @@ public class SortServiceImplTest extends ServiceBaseTest {
         request.setUrl("test_hive_url");
         request.setName(taskName);
         
request.setExtParams("{\"paramKey1\":\"paramValue1\",\"hdfsUgi\":\"test_hdfsUgi\"}");
-        request.setHdfsPath("testPath");
+        request.setDataPath("testPath");
         request.setHiveConfDir("testDir");
         request.setWarehouse("testWareHouse");
         request.setHdfsUgi("testUgi");