Set HDFS user

Use DB.login as HDFS write user.

Issue-ID: DCAEGEN2-1498
Change-Id: I59ee83472595b1fc79e9562b68f4178e7fbd920b
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>

diff --git a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
index 04299e6..2884c3e 100644 (file)
--- a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
+++ b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
@@ -82,7 +82,7 @@ insert into db (`name`,`host`,`login`,`pass`,`database_name`) values ('Couchbase
 insert into db (`name`,`host`) values ('Elasticsearch','dl_es');\r
 insert into db (`name`,`host`,`port`,`database_name`) values ('MongoDB','dl_mongodb',27017,'datalake');\r
 insert into db (`name`,`host`) values ('Druid','dl_druid');\r
-insert into db (`name`,`host`) values ('HDFS','dlhdfs');\r
+insert into db (`name`,`host`,`login`) values ('HDFS','dlhdfs','dl');\r
 \r
 \r
 -- in production, default enabled should be off\r

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
index e8d2910..edbc675 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
@@ -140,8 +140,10 @@ public class HdfsService {
 
                        String hdfsuri = String.format("hdfs://%s:%s", hdfs.getHost(), port);
                        hdfsConfig.set("fs.defaultFS", hdfsuri);
-
-                       log.info("Connecting to -- {}", hdfsuri);
+                       //hdfsConfig.set("hadoop.job.ugi", hdfs.getLogin());
+                       System.setProperty("HADOOP_USER_NAME", hdfs.getLogin());
+                       
+                       log.info("Connecting to -- {} as {}", hdfsuri, hdfs.getLogin());
 
                        fileSystem = FileSystem.get(hdfsConfig);